如何在RxJava中执行递归Observable调用？
我对RxJava（以及一般的反应模式）颇为陌生，所以请耐心等待。
假设我有这个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]的评论？
**
我搜索了这个：偶然
这是递归函数：
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。 我怎么做？
任何帮助都感激不尽。
这与文章中描述的几乎相同：
Observable<Comment> getInnerComments(Comment comment) {
if (comment.childIds.length > 0)
return Observable.merge(
Observable.just(comment),
Observable.from(comment.childIds)
.flatMap(id -> getComments(id))
.flatMap(this::getInnerComments));
return Observable.just(comment);
}
public static void main(String[] args) {
getComments(1)
.flatMap(this::getInnerComments)
.subscribe(c -> System.out.println(comment.toString()));
}
我从id = 1的评论开始，然后将它传递给getInnerComments() 。 getInnerComments()检查注释是否有子项。 如果是的话，它遍历每个子id（ Observable#from ）并用你的getComments(int) API加载每个子getComments(int) 。 然后每个孩子都被传递给getInnerComments()来执行相同的过程。 如果评论没有孩子，则立即使用Observable#just返回。
这是伪代码，并没有经过测试，但你应该明白。
以下是如何获取所有评论并将它们聚合到一个List<Comment>的示例。
getNews(99)
.flatMap(news -> Observable.from(news.commentIds))
.flatMap(commentId -> getComments(commentId))
.flatMap(comment -> getInnerComments(comment))
.toList()
.subscribe(commentList -> { });