如何为 Flowable<List<String>> 中的每个 id 获取用户对象

Question

我有一个代表组中用户 ID 的 ID 列表的 Flowable。

private val memberIdsFlowable: Flowable<List<String>> = groupFlowable
        .map { it.members }

我需要打电话

fun fetchUserFlowable(id: String): Flowable<User>

对于列表中的每个 id 并将它们组合成用户列表Flowable<List<User>>

我试过的是这样的：

private val membersFlowable = memberIdsFlowable
    .concatMap { list ->
        Flowable.fromIterable(list)
            .map { userRepository.fetchUserFlowable(it) }
    }

但它会导致Flowable<Flowable<User>> 而不是Flowable<List<User>>，如果我添加toList() 运算符，那么这是类型不匹配：

   private val membersFlowable = memberIdsFlowable
    .concatMap { list ->
        Flowable.fromIterable(list)
            .map { userRepository.fetchUserFlowable(it) }
            .toList()
    }

Answer 1

你只需要在里面也有concatMap：

private val membersFlowable = memberIdsFlowable
    .concatMap { list ->
        Flowable.fromIterable(list)
            .concatMap { userRepository.fetchUserFlowable(it) }
    }

因此 lambda 为每个 list 返回 Flowable<User>。

编辑：如果您希望memberIdsFlowable 中的每个List<String> 都有一个List<User>，则外部操作应为map。我不太确定它的论点，但我认为这样的事情应该可行：

private val membersFlowable = memberIdsFlowable
    .map { list ->
        Flowable.fromIterable(list)
            .concatMap { userRepository.fetchUserFlowable(it) }
            .toList()
    }