[RxKotlin] Reactive 코틀린 #10 - 병렬처리를 위한 Scheduler
Observable은 기본적으로 subscribe하는 thread에서 동작됩니다.interval이나, timer로 Observable을 생성하거나, delay operator를 사용하는 경우가 아니고서는 subscribe가 완료될때까지 thread가 block됩니다.즉 subscribe{..} 블럭에서 모든 데이터를 수신받고 처리해야하만 해당 블럭을 벗어날 수 있는거죠. 그럼 일단 간단하게 test해 봅니다.fun main(args: Array) = runBlocking { val ob = Observable.just(1, 2, 3) .map { println("map: $it - ${Thread.currentThread().name}") it } ob.subscribe { println("First: ..
