RXサブ観測可能 - 実行は一度だけ

Question

通常、私はそれが1回だけ実行され、観察可能なを作成するために

Observable observable = someObservable.replay().refCount(); 

を使用しています。私は、次のような observable複数回に加入する場合、これが正常に動作します：

observable.observeOn(Schedulers.io()) 
    .subscribeOn(AndroidSchedulers.mainThread()) 
    .subscribe(...); 

observable.observeOn(Schedulers.io()) 
    .subscribeOn(AndroidSchedulers.mainThread()) 
    .subscribe(...); 

observable一度だけ実行される - 完璧な、私はそれをしたいだけのよう。今私が次のようにしている場合：

Observable obs1 = observable.map(...); // call some operators 
Observable obs2 = observable.map(...); // call some operators 

obs1.observeOn(Schedulers.io()) 
    .subscribeOn(AndroidSchedulers.mainThread()) 
    .subscribe(...); 

obs2.observeOn(Schedulers.io()) 
    .subscribeOn(AndroidSchedulers.mainThread()) 
    .subscribe(...); 

次に、observableが2回実行されます。これが起こらないことをどうすれば確認できますか？

Answer 1

あなたが望むのは、.take(1)演算子を追加することです。これにより、オブザーバブルから何かが読み込まれると、onCompleteが呼び出されます。