我在类(A)中创建了一个任务,然后异步调用,然后如果任务完成或取消,传递结果另一个类(B),在rxJava2中使用,在rxJava2中是非常新的,我可以使用这个逻辑吗?I confused.What?可完成的还是可流动的?
我想做的是
调用异步任务类(B),运行任务并发出一些结果类(A),然后在类(B)中订阅任务结果,你有什么想法吗?感谢您的建议
发布于 2019-01-17 20:11:15
因此,您将一些任务A和B公开为streams。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。
https://stackoverflow.com/questions/54231142
复制相似问题