[RxKotlin] Reactive 코틀린 #8 - skip, take operators
Observable이 생산하는 값들중 일부를 skip하거나 반대로 일부만 take하는 operator들에 대해 설명합니다. skipskip 연산자는 말그대로 방출시점에 조건에 따라 방출을 전달하지 않습니다. fun main(args: Array) = runBlocking { val ob = Observable.intervalRange(1, 10, 0, 100, TimeUnit.MILLISECONDS) println("----- skip(count) ------") ob.skip(5) .blockingSubscribe{ println(it) } println("----- skip(time) ------") ob.skip(300, TimeUnit.MILLISECONDS) .blockingSubscribe{ ..