代码之家  ›  专栏  ›  技术社区  ›  TsigumEnes

如何在RXJava2中交流自定义任务和另一个类?

  •  0
  • TsigumEnes  · 技术社区  · 6 年前

    我在类(a)中创建了一个任务并异步调用,然后如果任务完成或取消,则将结果传递给另一个在rxjava2中使用的类(b)。在rxjava2中我是个新手,我很困惑。我可以使用什么逻辑? 可完成还是可流动?

    我想做什么

    异步调用任务类(B) 运行任务并发出一些结果类(A) 然后在类(B)中订阅任务结果 有什么想法吗?谢谢你的建议

    1 回复  |  直到 6 年前
        1
  •  0
  •   Tuby    6 年前

    所以您有一些任务A和B作为流公开,例如。 Single<TaskAResult> Single<TaskBResult> . 任务A发出结果后,使用flatmap订阅任务B。

    taskA.flatMap(taskAResult -> taskB(taskAResult))
            .subscribe(taskBResult -> {
                // do whatever after task B finishes
            });
    

    你有一个方法 Single<TaskBResult> taskB(TaskAResult result) 它将根据任务A的结果创建任务B。