AndroidでのRxJavaとランダムな散発的なイベント

Question

私はGuavaのEventBusやOttoを使ったのと同じようにRxJavaを使いたいですが、どうやってそのように機能するのか分かりません。

これはシナリオです：私はAndroidアプリにボタンを持っていて、ボタンが押されるたびにRxJavaがObservableを介してイベントを放出したいとしましょう。それはイベントを取得した後、私はサービスreregisterを持っている必要があり、その活動は新しいobservableを作成する必要があると私には思われる。

私は

Observable.from(x) 

言う場合と同じように、私はすべてのイベントのためにそれに必要となるように思えるが、それはに再登録する必要があるであろう新しい観察できるが作成されます。確かに私は何かが欠けている。あなたがに応じて活動（またはその逆にサービスとPublishSubjectに件名インターフェイスを注入することができれば

PublishSubject<Object> subject = PublishSubject.create(); 
// observer1 will receive all onNext and onCompleted events 
subject.subscribe(observer1); 
subject.onNext("one"); 
subject.onNext("two"); 
// observer2 will only receive "three" and onCompleted 
subject.subscribe(observer2); 
subject.onNext("three"); 
subject.onCompleted(); 

：

Answer 1

あなたは、この（rx.subjects.PublishSubjectから）のような何かをしたい場合があります何をしているのか）、あなたは懸念の良い分離を持つことができます。

Answer 2

The newly added refCount operator for ConnectableObservable being added in 0.14.3も、このタイプのユースケースで役に立ちます。

複数のオブザーバーが出入りする際の自動接続/切断をサポートしています。