Schedulers.computation() выполнен на MainThread

Question

Как я могу выполнить этот код в фоновом потоке?

.subscribeOn(Schedulers.computation()) 

onNext() 
{ 
    touchEverythingInTheUiThreadFromBackgroundThread(); 
} 

Answer 1

Использование

Observable.fromCallable(() -> Thread.currentThread().getName()) 
      .subscribeOn(Schedulers.computation()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(name -> Timber.d("Worker thread: %s, Handle thread: %s", name, Thread.currentThread().getName())); 

Answer 2

Если вы хотите быть уверены, что ваш .doOnNext() выполняется на указанном планировщиком, а затем изменить ваш .subscribeOn() к .observeOn(). Интуитивно .observeOn() определяет, какой планировщик используется для всего, что приходит после этого.

.subscribeOn() влияет только на то, что планировщик используется для запуска onSubscribe() метод вашего наблюдаемого создания. То, что происходит позже, в значительной степени зависит от того, что именно вы подписываетесь или как @akarnokd ставит его: что является источником ваших событий. Небезопасно предполагать, что элементы будут отправляться в планировщик, указанный в .subscribeOn(). На самом деле существует, по крайней мере, несколько примеров, когда эти предположения не выполняются.