Вопрос

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