我对RxJava（和一般的Reactive范式）很陌生，所以请多多包涵。

假设我有这个News和这个嵌套的Comment数据结构：

public class News {
  public int id;
  public int[] commentIds; //only top level comments
  public News(int id, int[] commentIds) {
    this.id = id;
    this.commentIds = commentIds;
  }
}

public class Comment {
  public int id;
  public int parentId; //ID of parent News or parent comment
  public int[] childIds;
  public Comment(int id, int parentId, int[] childIds) {
    this.id = id;
    this.parentId = parentId;
    this.childIds = childIds;
  }
}

并假设我有以下API端点：

getComments(int commentId) //return Observable<Comment> for Comment with ID commentId

现在，让我们假设：

getComments(1); //will return Comment(1, 99, [3,4])
getComments(2); //will return Comment(2, 99, [5,6])
getComments(3); //will return Comment(3, 1, [])
getComments(4); //will return Comment(4, 1, [])
getComments(5); //will return Comment(5, 2, [])
getComments(6); //will return Comment(6, 2, [])

**

现在，如果有的话News n = News(99, [1,2])，如何递归所有子项评论？即获得ID为[1,2,3,4,5,6]的评论？

**

我已经搜索并偶然发现了这个：https : //jkschneider.github.io/blog/2014/recursive-
observables-with-
rxjava.html

这是递归函数：

public class FileRecursion {
    static Observable<File> listFiles(File f) {
        if(f.isDirectory())
            return Observable.from(f.listFiles()).flatMap(FileRecursion::listFiles);
        return Observable.just(f);
    }

    public static void main(String[] args) {
          Observable.just(new File("/Users/joschneider/Desktop"))
                  .flatMap(FileRecursion::listFiles)
                  .subscribe(f -> System.out.println(f.getAbsolutePath()));
    }
}

它显示了有关如何进行递归可观察调用的示例，但内部函数（f.listFiles()）是阻塞操作（不会返回另一个Observable）。就我而言，内部函数（getComments）是一个非阻塞函数，它返回另一个Observables。我怎么做？

任何帮助都感激不尽。