java - 组合多个 Single 的最有效方法是什么> 成为单曲>?

Question

我有一个loadApplesById接受 aAppleId并返回 a的函数Single<List<Apple>>。

在另一个函数中，loadApplesByIdList我接受 aList<AppleId>作为参数。对于其中的每个元素，我必须调用loadApplesById. 也将loadApplesByIdList返回一个Single<List<Apple>>.

像这样的东西：

Single<List<Apple> loadApplesById(AppleId appleId)
{
    // magic to create and load the apple list.
    return the Single.just(AppleList);
}


Single<List<Apple> loadApplesByIdList(List<AppleId> appleIdList)
{
    // My question how to create this function (?)
    // Approach (1)
    return Observable.from(appleIdList).flatMap(
        appleId -> this.loadApplesById(id)
        .toObservable())
        .reduce(new ArrayList<>(), (List<Apple> a, List<Apple> b)
            -> { a.addAll(b); return a; }).toSingle();

    // Approach (2)
    return Observable.from(appleIdList).flatMap(appleId -> loadApplesById(id)
            .toObservable())
            .toSingle();

}

虽然这两种方法都可以编译，但它们都不起作用。

如果有人花时间详细说明可以实现这一点的不同方法（使用 fold、reduce、flatMap、concatMap）等，那将是一个很好的学习课程。

标签： javamultithreadingrx-javareactive-programming

Answer 1

您必须展开每个单曲，将它们连接起来，然后再次收集它们：

Single<List<Apple>> allApples = 
    Observable.fromIterable(appleIdList)
    .concatMap(appleId -> 
         loadApplesById(appleId)
         .flattenAsObservable(list -> list)
    )
    .toList();

不过，您需要 RxJava 2。