我目前正在使用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。
添加回答
举报
0/150
提交
取消