rxjava
-
RxJava2로 EventBus 구현 하기 (Rxbus)Android/Rx 2020. 3. 20. 14:09
https://github.com/DNights/RxBusSample DNights/RxBusSample Contribute to DNights/RxBusSample development by creating an account on GitHub. github.com EventBus를 사용중 Dexguard 사용시 문제되는 부분이 있어 Rx 를 이용하여 EventBus 처럼 사용 할 수 있도록 변경하였습니다. RxBus.kt import io.reactivex.subjects.PublishSubject import java.util.* object RxBus { val instance = RxBus private val subjectTable = Hashtable() fun sendEvent(any: A..
-
SubscribeOn 와 ObserveOn 그리고 SchedulersAndroid/Rx 2019. 10. 7. 00:03
SubscribeOn SubscribeOn은 구독(subscribe)에서 사용할 스레드를 지정 도중 ObserveOn이 호출되어도 SubscribeOn의 스레드 지정에는 영향을 끼치지 않는다. ObserveOn ObserveOn은 Observable이 다음처리를 진행할때 사용할 스레드를 지정 ObserveOn이 선언된 후 처리가 진행뒤 다른 ObserveOn이 선언시 다른 ObserveOn에서 선언한 스레드로 변경되어 이후 처리를 진행한다. Schedulers Observable 연산자 체인에 멀티스레딩을 적용하고 싶다면, 특정 스케줄러를 사용해서 연산자(또는 특정 Observable)를 실행하면 된다. ReactiveX의 일부 Observable 연산자는 사용할 스케줄러를 파라미터로 전달 받기도 하는데..
-
ReactiveX - SubjectAndroid/Rx 2019. 9. 4. 11:33
https://github.com/DNights/rxSubjectSample DNights/rxSubjectSample Contribute to DNights/rxSubjectSample development by creating an account on GitHub. github.com RxSubject 에 관한 내용을 정리하였습니다. RxSubject는 아래 4가지 종류가 있습니다. AysncSubject BehaviorSubject PublishSubject ReplaySubject AysncSubject는 구독이 끝나고 가장 마지막값을 전달합니다. fun runOnNextWithAsyncSubject(){ for (i in 0..100){ asyncSubject.onNext("asyncSubjec..