I filter the notification observable to only show erros and replay the last error if I subscribe from it from inside my click observable.

Now my question is, are there any operators in RxJava by which I can do this more... neatly? I tried to use

combineLatest()

but this had the effect, that every time an error ocured the dialog would open.

In a more abstract way: I have two observables, one is like the "master": If the master observable (click observable) emits an item, the other observable (my error notifications) should emit the latest item.