我目前正在使用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。
相关分类