Как я могу связать пользовательское задание и другой класс в rxJava2?

Question

Я создаю задачу в классе (A) и вызываю асинхронно, затем, если задача завершена или отменена, передайте результат другому классу (B) с использованием в rxJava2. Я очень новичок в rxJava2, и я запутался. Что я могу использовать? это логика? Завершаемый или текучий?

Что я хочу сделать

вызов асинхронного класса задач (B) запустить задачу и выдать некоторый класс результата (A) затем подпишите результат задачи в классе (B) Любая идея ? Спасибо за ваше предложение

Answer 1

Итак, у вас есть задачи A и B, представленные в виде потоков, напр. Single<TaskAResult> и Single<TaskBResult>. Используйте flatMap, чтобы подписаться на задачу B после того, как задача A выдаст результат.

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

И у вас есть метод Single<TaskBResult> taskB(TaskAResult result), который создаст задачу B на основе результата задачи A.