如何使用将 X 作为参数并返回 Observable<Y> 的函数从 Observable<List<X>> 转换为 Observable<List<Y>>

Question

我有一个方法可以无限期地（不是有限地）发出用户 ID 列表。

Observable<List<String>> getFriendUserIds()

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

Observable<Account> getAccount(String userId)

我需要获取 getFriendUserIds() 方法返回的所有用户 id 的 Account 数据，并在与用户 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> 必须包含与List<String> 中存在的每个用户ID 相对应的Accounts。

**请注意，此问题类似于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()
);