RxJava 2.0의 PublishSubject 구독

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에 체인 여러 사업자/구독 할 수 있습니다.