Android-RX子可观察-仅执行一次

概述通常我用Observableobservable=someObservable.replay().refCount();创建一个只能执行一次的可观察对象.如果我多次订阅可观察的内容,则效果很好,如下所示：observable.observeOn(Schedulers.io()).subscribeOn(AndroidSchedulers.mainThread()).subscribe(...);

通常我用

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

创建一个只能执行一次的可观察对象.如果我多次订阅可观察的内容,则效果很好,如下所示：

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

可观察对象仅执行一次-完美,正如我想要的那样.如果我现在执行以下 *** 作：

Observable obs1 = observable.map(...); // call some operatorsObservable obs2 = observable.map(...); // call some operatorsobs1.observeOn(Schedulers.io())    .subscribeOn(AndroIDSchedulers.mainThread())    .subscribe(...);obs2.observeOn(Schedulers.io())    .subscribeOn(AndroIDSchedulers.mainThread())    .subscribe(...);

然后,可观察对象执行两次.我如何确保不会发生这种情况？

解决方法:

我认为您想要添加一个.take(1)运算符.这样,一旦从可观察对象读取了某些内容,它将调用onComplete.

总结

以上是内存溢出为你收集整理的Android-RX子可观察-仅执行一次全部内容，希望文章能够帮你解决Android-RX子可观察-仅执行一次所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。