Как связать несколько предметов?

Я новичок в RXJava. У меня есть несколько задач, которые должны быть обработаны последовательно.

BehaviorSubject<String> task1 = BehaviorSubject.create();
BehaviorSubject<String> task2 = BehaviorSubject.create();
BehaviorSubject<String> task3 = BehaviorSubject.create();

/* SUBSCRIBING */
task1.doOnNext(s -> System.out.print(" task1")).subscribe(s -> task2.onNext(s));
task2.doOnNext(s -> System.out.print(" task2")).subscribe(s -> task3.onNext(s));
task3.doOnNext(s -> System.out.println(" task3")).subscribe();

task1.onNext("");
task2.onNext(""); // insert data to start from task2
task3.onNext(""); // insert data to start from task3

Можно ли сделать эту ПОДПИСКУ частью одной строки с Rx API?

0 ответов

Другие вопросы по тегам