RxJava 스케줄러의 핵심은 결국 제공되는 스케줄러의 종류를 선택한 후 subscribeOn()과 observeOn() 함수를 호출하는 것이라고 할 수 있습니다.
subscribeOn()
Observable에서 구독자가 subscribe() 함수를 호출했을 때 데이터 흐름을 발행하는 스레드를 지정하는 역할을 합니다. subscribeOn() 함수는 처음 지정한 스레드를 고정시키므로 다시 subscribeOn() 함수를 호출해도 무시합니다.
observeOn()
처리된 결과를 구독자에게 전달하는 스레드를 지정하는 역할을 합니다.
observeOn()은 여러 번 호출할 수 있으며 호출되면 그다음부터 동작하는 스레드를 바꿀 수 있다.
observeOn()함수를 지정하지 않으면 subscribeOn() 함수로 지정한 스레드에서 모든 로직을 실행하게 됩니다.
[ 출처 : RxJava 프로그래밍 ]
728x90
반응형
'Domain > ReactiveX' 카테고리의 다른 글
[ReactiveX] Scheduler (0) | 2021.04.29 |
---|---|
[ReactiveX] ConnectableObservable (0) | 2021.04.29 |
[ReactiveX] Subject (0) | 2021.04.29 |
[ReactiveX] Cold Observable Vs Hot Observable (0) | 2021.04.29 |
[ReactiveX] Maybe (0) | 2021.04.29 |
댓글