Comment préserver rx Scheduler sans l'avoir comme paramètre de méthode?

Question

Si je fais quelque chose comme ceci:

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

puis filetage intérieur sera « fuite » à la chaîne principale observable. Comment conserver le fil d'origine?

Merci d'avance!

Answer 1

Vous devez spécifier le même programmateur avant et après la flatMap

Scheduler scheduler = ... 

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

Si vous voulez revenir au même fil exact, vous pouvez spécifier un seul programmateur fileté:

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

utiliser le pas vraiment pour-public-consommation

scheduler = new SingleScheduler(); 

ou prenez l'un des planificateurs standard et utilisez les SharedScheduler du projet d'extension RxJava 2:

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