[RxJava] 햇갈리던 subscribeOn, observeOn 의 thread 관계 정리 - subscribeOn 은 최초 호출의 것만 valid 하고, 그 이후에 사용하는 것은 모두 무시된다. - subscribeOn 은 처음 시작부분의 thread 를 결정하고, observeOn 을 만나는 순간부터 observeOn 에서 명시한 thread 로 변경된다. - just 를 사용하면 subscribe 시점이 아니라, 호출되는 시점에 바로 연산이 수행된다. subscribeOn 에서 명시한 thread 가 아닌 just 를 호출한 thread 에서 바로 호출된다. 메인에서 호출하면 loadDataSync 자체는 mainThread 에서 연산된다는 것이다. 그림에서 빨간 줄이 약간 혼란스러움을 줄 수 있는데, subscribing 자체는 io thread 에서 잘 수행된다. 이 말은 연산 자체는.. 2021. 5. 7. [RxJava] #4 리액티브 연산자의 활용 4.1. 생성 연산자 -생성 연산자의 역할은 데이터 흐름을 만드는 것이다.간단하게 Observable, Single, Maybe 객체 등을 만든다고 생각하면 된다. 4.1.1. interval() 함수 -일정 시간 간격으로 데이터 흐름을 생성한다.주어진 시간 간격으로 0부터 1씩 증가하는 Long 객체를 반환한다. -interval() 함수는 기본적으로 영원히 지속 실행되기 때문에 폴링 용도로 많이 사용된다.수행은 RxComputationalThreadPool 에서 수행된다.interval 값이 초기 지연값으로도 활용된다. 4.1.2. timer() 함수 -interval 함수와 유사하지만 한 번만 실행하는 함수.일정 시간이 지난 후에 한 개의 데이터를 발행하고 onComplete() 이벤트가 발생한다... 2019. 6. 5. 반응형 이전 1 다음
