RxJava中单线程ExecutorService的等价物是什么？
RxJava中单线程ExecutorService的等价物是什么？
提问于 2017-02-22 22:52:41
我希望用RxJava代替我的单线程ExecutorService
private ExecutorService executor = Executors.newSingleThreadExecutor();
executor.submit(/* ... */);我想知道使用RxJava的等效设置是什么？到目前为止，我尝试了以下几点：
private Subject<MyClass> subject = PublishSubject.create()
subject.toFlowable(MISSING)
.observeOn(Schedulers.single())
.subscribeOn(Schedulers.single())
.subscribe(obj -> {
// handle on next
});这是等同于我上面的ExecutorService设置还是不同？我是否可以通过Schedulers.single()获得新的单线程执行器
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/42394848
复制相关文章
相似问题