Подписаться на PublishSubject в RxJava 2.0

Question

У меня есть следующий код, который отлично работал в RxJava 1.6.

private PublishSubject<Boolean> mConnectionSubject; 
... 
Observable.create(subscriber -> { 
     mConnectionSubject.subscribe(subscriber); 
     ... 
    }); 

Но после перехода на RxJava 2.0 этот код не компилируется. Причина в том, что Observable.create() теперь принимает в качестве аргумента ObservableEmitter. Но PublishSubject не принимает ObservableEmitter. Он принимает только интерфейс Consumer или Observer.

Получу любые предложения.

Answer 1

Я бы сделал что-то вроде ниже в упомянутом вами сценарии.

Observable.<Boolean>create(emitter -> mConnectionSubject.subscribe(
    emitter::onNext, 
    emitter::onError, 
    emitter::onComplete 
)); 

Answer 2

Вам не нужно создавать новый наблюдаемыми, это должно работать:

private PublishSubject<Boolean> mConnectionSubject; 
... 
mConnectionSubject.doOnNext(...).observeOn(...).subscribe(); 

Вы можете цепь несколько операторов/подписки на PublishSubject.