嵌套平面图可观察rxJava

Question

假设我有一个返回列表的博客帖子api

• 从列表创建可观察
• 将每个可观察拆分为可观察

我很难弄清楚如何在特定术语上进行多层次的拆分和组合。如果我只需要拆分成页面，我可以做一些类似于平面图（观测e::from）. toList（）的事情，但这似乎不起作用。任何帮助都将不胜感激。




Answer 1

匿名用户

我认为这样的东西应该可以正常工作，代码非常不言自明。

我从对进行了一些嵌套调用，以将帖子拆分为段落，将段落拆分为单词。然后，我使用可观察的reduce来连接单词以获得单个段落，然后再次使用reduce将段落连接到单个帖子。

Observable<List<String>> blogPostsWithReversedWords(List<String> blogPosts) {
    return Observable.from(blogPosts)
            .flatMap(this::blogPostToParagraphs)
            .toList();
}

Observable<String> blogPostToParagraphs(String post) {
    return Observable.from(post.split("\n"))
            .flatMap(this::paragraphToWords)
            .reduce((prevText, nextParagraph) -> prevText + "\n" + nextParagraph);
}

Observable<String> paragraphToWords(String paragraph) {
    return Observable.from(paragraph.split(" "))
            .map(this::reverseWord)
            .reduce((prevText, nextWord) -> prevText + "\n" + nextWord);
}

String reverseWord(String word) {
    return new StringBuilder(word).reverse().toString();
}