非同期でやるには?どこからが非同期で実行されるの? Observableの実装や叩いたOperator(map()やfilter()などのメソッド)によりますが、基本的に現在のスレッド(subscribe()を呼び出したスレッド)で「同期的に」実行されます。 ドキュメントに Scheduler: This version of XXX does not operate by default on a particular Scheduler. と書かれているものは、現在のスレッドで実行されます from(): 現在のスレッドで実行されます Subject: onNext()などを呼び出したスレッドで実行されます ドキュメントのScheduler欄にそれ以外の事が書かれている場合はそれに準じます repeat(Scheduler scheduler)のようにschedulerを引数に取る場合