Вопрос
Абзалboolean connected = true; PublishSubject<String> messages = PublishSubject.create(); messages.subscribe(message -> { // Что я должен сделать, чтобы получать сообщения только если connected равен true и не терять сообщения System.out.println(message); }); messages.onNext("A"); messages.onNext("B"); messages.onNext("Hi"); connected = false; messages.onNext("C"); connected = true; messages.onNext("D");
Output:
A
B
Hi
C
D