리액티브 코틀린 연산자 검색 결과

해당 글 6건
반응형

[RxKotlin] Reactive 코틀린 #12 - Custom operators

기존 포스팅에서는 RxKotlin에서 제공하는 operators에 대해서 설명했습니다.물론 기본적으로 RxJava의 내용이지만 Collection.toObservable() 같은 kotlin 확장 함수도 같이 설명되었습니다.추가적으로 Observable이나 Flowable에 Extension function을 추가하지 않고도 커스텀 연산자를 선언하여 사용할 수 있습니다. 얼마나 자주 사용할지는, 개개인의 성향과 Custom operator가 얼마나 자주 사용되는지 빈도에 따라 결정되겠지만 일단은 지원한다는데 더 초점을 맞춰서 설명해 보도록 하지요. ㅎㅎ lift && ObservableOperatorObserver로 선언된 부분을 custom하게 변경 하기 위하여 lift 함수를 제공하며, 인자로 Obs..
개발이야기/Kotlin 2019. 12. 23. 23:41

[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: ..
개발이야기/Kotlin 2019. 12. 20. 11:20

[RxKotlin] Reactive 코틀린 #9 - Error handling operators

Observer 나 Subscriber 객체에 onError() 함수를 override하면 생산자에서 발생하는 error를 전달받을수 있습니다.하지만 onError()을 사용하지 않고, 중간 연산자로 error을 처리하는 방법에 대해서 알아봅니다. 먼저 기본적으로 에러를 발생시키도록 코드를 작성합니다.fun main(args: Array) { Observable.range(1, 10) .map { if (it == 5) { throw Exception("Error!!!") } else { it } } .subscribeBy ( onNext = { println(it) }, onError = { e -> println(e) } ) } 예상대로 5를 찍으면 exception을 throw 합니다.1234jav..
개발이야기/Kotlin 2019. 12. 19. 14:13

[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{ ..
개발이야기/Kotlin 2019. 12. 19. 12:54

[RxKotlin] Reactive 코틀린 #7 - Composing operators

생산자를 병합하는 Operator에 대해서 설명합니다.기본적인 구현이나 내용은 Coroutine flow의 연산자와 동일합니다.필요에 따라서 flow의 내용을 언급하며, 상세한 내용은 하기 링크에서 확인할 수 있습니다.2019/11/16 - [개발이야기/Kotlin] - [Kotlin] 코틀린 - 코루틴#11- Asynchronous Flow(2/2) startWith이전에 이미 언급한 연산자로 Observable의 앞쪽에 데이터를 끼워 넣습니다.이전 예제에서는 단일값을 넣는 형태 였지만 다른 Observable(flowable)을 앞쪽에 끼워 넣을수도 있습니다. 만약 list를 전달한다면, 내부적으로는 Observable로 변경되어 처리됩니다.아마도 .toObservable()을 사용하겠죠? fun m..
개발이야기/Kotlin 2019. 12. 18. 17:17

[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
반응형