rx 검색 결과

해당 글 3건
반응형

[RxKotlin] Reactive 코틀린 #3 - Subject

Hot observable을 구현시 publish() 이외에 subject를 이용할 수 도 있습니다.Subject는 Observer 역할을 하기 때문에 여러 Observable에 구독을 신청할 수 있고, Overvable의 역할도 하기 때문에 받은 item을 재배출 하거나, 새로운 값을 배출할 수 있습니다.Observable이면서 Observer인거죠. subject를 설명하기 위한 마블 다이어그램은 하기 링크에서 작성된 자료를 사용했습니다.http://reactivex.io/documentation/ko/subject.html 편의를 위해 delay를 kotlin coroutine의 runBlocking을 이용합니다.(runBlocking으로 thread를 정지시키지는 않지만 delay가 있는 라인에서..
개발이야기/Kotlin 2019. 12. 6. 17:57

[RxKotlin] Reactive 코틀린 #2 - Observable, ConnectableObservable

Observable은 Consumer가 소비하는 값을 생성하는 역할을 합니다. Consumer들은 Observable에 구독을 신청하고, Observable은 값을 생성한 후에 Consumer들에게 push 방식으로 값을 전달합니다. Observable의 주요 이벤트 Observable은 주요하게 아래 event를 발생시킵니다. onNext(item T): 값을 전달할때 호출하여 값을 넘겨줌 onError(e: Throwable): 에러가 발생하면 호출함 onSubscribe(d: Disposable): 구독을 신청하면 호출해줌 이때 넘어오는 Disposable 객체는 Observer가 구독을 해제할때 사용함. onComplete(): 가지고 있는 값을 모두 전달하면 호출함. 따라서 위 callback ..
개발이야기/Kotlin 2019. 12. 4. 18:46

[RxKotlin] Reactive 코틀린 #1 - 개념 및 설치

Reactive program은 옵져버 패턴을 이용하여 구독자에게 변경사항을 알려주는 programming 기법 입니다.내가 어떤 데이터가 필요하여 요청하고, 그 데이터를 얻어와 가공하는게 아니라, 데이터 관리주체쪽에 데이터가 변경시 요청을 받겠다는 구독신청을 해놓고, 변경사항(event)이 발생하면 이를 전달 받습니다.보통 프로그래밍을 하는 방법과는 반대되는 설정이죠.따라서 reactive programming은 하나의 값을 반환하기 보다는 data stream을 반환합니다.ReactiveX의 개념은 iterator와 비교되는데, 좀더 명확하고 자세한 설명이 필요하다면 아래 페이지를 참고하면 됩니다.http://reactivex.io/intro.html Rx의 개념은 여러 언어로 개발되고 있습니다. 여..
개발이야기/Kotlin 2019. 12. 4. 09:15
반응형