如何通过可迭代的/列表动态链接Observables?

我目前正在使用RxJava,并且我有类似的内容,


List<Integer> taskIds = ...


Observable.just(new Task(taskIds.get(0)))

        .compose(executeWorkFlow())

        .filter(Response::isSuccess)

        .flatMap(res -> Observable.just(new Task(taskIds.get(1)))

        .compose(executeWorkFlow())

        .filter(Response::isSuccess)

        .flatMap(res -> Observable.just(new Task(taskIds.get(2)))

        .compose(executeWorkFlow())

        .filter(Response::isSuccess)

        ...

execute()是执行API调用并返回响应的Transformer,即


ObservableTransformer<Task, Response> execute() { ... }

有没有更好的方法来编写此代码?鉴于我将不知道从先前的Observable会发出多少个任务ID。


慕后森
浏览 145回答 1
1回答
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java