2019/12/16 검색 결과

해당 글 3건
반응형

[RxKotlin] Reactive 코틀린 #6 - Basic operators

RxKotlin에도 Collection과 유사한 연산자들이 존재합니다.가장 친숙한 연산자인 filter나 map을 비롯하여 다양한 연산자를 제공합니다. Kotlin이나 java stream에서 Collection 관련 연산자를 많이 써봤다면, RxKotlin의 연산자 역시 쉽게 이해할수 있습니다.(사실 역할은 똑같습니다.)다만 입력이 Observable 또는 flowable이고, 연산자를 거쳐서 나오는 출력또한 Observable 또는 flowable입니다. 이미 Collection에서 많이 사용하는 연산자는 예제없이 간단하게 언급만하고 넘어가며, collection에 있더라도 잘 쓰지 않았던 연산자나, RxKotlin용 연산자 위주로 예제와 함께 설명합니다. filter기존 collection에서 사용..
개발이야기/Kotlin 2019. 12. 16. 15:41

[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..
개발이야기/Kotlin 2019. 12. 16. 09:24
반응형