RX суб наблюдаемым - выполнить только один раз

Question

Обычно я использую

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 выполняется дважды. Как я могу убедиться, что этого не произойдет?

Answer 1

Я думаю, что вы хотите добавить оператора .take(1). Таким образом, как только что-то прочитано из наблюдаемого, оно вызовет onComplete.