[RxKotlin] Reactive 코틀린 #5 - Processor, sample, throttle, window, buffer
예제에서는 생산의 속도, 소비의 임의 속도 조절을 위해 kotlin의 corouitne을 사용합니다. runBloking을 사용하여 structured concurrency를 보장하도록 하며, suspend function인 delay()를 사용하여 thread block 없이 코드를 지연시키도록 합니다.여기서 다루는 내용은 아니지만 coroutine에 대한 자세한 내용은 하기 링크를 참고 바랍니다.https://tourspace.tistory.com/283 추가적으로 Operator에 관한 내용은 하기 링크를 참고하였습니다.https://github.com/ReactiveX/RxJava/wiki/Backpressure ConnectableFlowable이전에 사용했던 flowable은 cold obse..
