java - 如何使用以 X 作为参数并返回 Observable 的函数从 Observable> 转换为 Observable>

Question

我有一个方法可以无限期地(非有限)发出用户 ID 列表。

Observable<List<String>> getFriendUserIds()

另一个方法返回 Account特定用户 ID 的数据。

Observable<Account> getAccount(String userId)

我需要获取Account getFriendUserIds() 方法返回的所有用户 ID 的数据，分组在与用户 ID 列表相对应的列表中。

基本上，我需要以下内容，最好是非阻塞方式。

Observable<List<String>> // infinite stream
===> *** MAGIC + getAccount(String userId) ***  
===> Observable<List<Account>> // infinite stream

示例:

["JohnId", "LisaId"]---["PaulId", "KimId", "JohnId"]------["KimId"]

===>

[<JohnAccount>, <LisaAccount>]---[<PaulAccount>, <KimAccount>, <JohnAccount>]------[<KimAccount>]

顺序并不重要，重要的是 List<Account>必须包含Account s 对应于 List<String> 中存在的每个用户 ID 。

**注意，这个问题类似于 this question ，但还有将结果项分组回列表的附加要求。

Answer 1

试试这个:

Observable<List<Account>> accountsList = getFriendUserIds()
.take(1)
.flatMapIterable(list -> list)
.flatMap(id -> getAccount(id))
.toList()
.toObservable();

或者这个:

Observable<List<Account>> accountsList = getFriendUserIds()
.flatMapSingle(list -> 
     Observable.fromIterable(list)
     .flatMap(id -> getAccount(id))
     .toList()
);