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にチェーン複数のオペレータ/サブスクリプションすることができます。