如何保留rx調度程序而不將它作爲方法參數？

Question

如果我做這樣的事情：

Observable.just(1) 
.flatMap(
    //inner chain 
    Observable.just(2) 
     .subscribeOn(Schedulers.newThread()) 
) 
.map(// we are in the inner chain thread! //) 
.subscribeOn(Schedulers.newThread()) 
.subscribe() 

然後內螺紋將「泄漏」到主觀察到鏈。 如何保留原始線程？

在此先感謝！

Answer 1

之前已指定相同的調度和flatMap

Scheduler scheduler = ... 

Observable.just(1) 
    .subscribeOn(scheduler) 
    .flatMap(v -> Observable.just(2).subscribeOn(newThread())) 
    .observeOn(scheduler) 
    .subscribe() 

如果之後要返回完全相同的線程，你可以指定一個單線程調度：

scheduler = Schedulers.from(Executors.newSingleThreadedExecutor()); 

使用不是真的爲公衆消費

scheduler = new SingleScheduler(); 

或採取任何標準的計劃和使用RxJava 2擴展項目的SharedScheduler：

scheduler = new SharedScheduler(Schedulers.computation());