Определение потока выполнения при использовании observeOn в RxJava

Нужно установить, в каком потоке будет выполнен оператор create и обработчик подписки, когда код запускается из главного (UI) потока.

Observable.create<Int> { }
    .observeOn(Schedulers.computation())
    .subscribe { }