使用doOnNext 完成轮询的耗时操作
在轮询操作中一般会进行一些耗时的网络请求,我们选择在doOnNext进行处理,它会在下游的onNext方法被回调之前调用,它的运行线程可以通过subscribeOn指定,下游的运行线程再通过observerOn切换会主线程。
使用doOnComplete 完成轮询的耗时操作
由于在订阅完成时会发送onComplete
消息,那么我们就可以在doOnComplete
中进行轮询所要进行的具体操作,它所运行的线程通过subscribeOn
指定。
网友评论