为了账号安全,请及时绑定邮箱和手机立即绑定

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

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

慕后森 2021-05-14 11:08:16
我目前正在使用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。
查看完整描述

1 回答

  • 1 回答
  • 0 关注
  • 144 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信