Mobile/RxJava2 [RxJava] Observable, Single, Completable Observable Single Completable Observable RxJava에서 Observer는 Observable을 구독한다. (예를 들어 ViewModel에서 어떤 API를 호출하면 ViewModel이 Observer 역할을 하고, API의 Response가 Observable이 된다.) 가장 기본적인 형태이며 연속적인 값을 emit 하면 그 값을 모두 구독해서 호출부에서 받을 수 있다. Emitter Event onNext : 정상적으로 emit한 값을 받을 때 호출되는 함수. onComplete : Observable 구독을 종료하면 호출되는 함수. onError : Observable 구독 중 에러가 발생하면 호출되는 함수. Single Observable과 달리 연속적인 값이 아닌 .. 2023. 10. 18. [RxJava] flatMap, concatMap, switchMap Observable transformation flatMap() concatMap() switchMap() Conclusion Observable transformation 현재 구독 중인 Observable 객체가 있고 이 객체의 결과 값을 변환해야 하는 경우가 종종 있다. 반드시 확장하고 더 풍부한 객체를 만들기 위함이 아니라, Observable 객체에서 반환되는 각각의 요소들을 merge 하는 과정을 거쳐 이러한 작업을 수행할 수도 있다. flatMap() flatMap() 메서드는 Original Observable 함수에서 새로운 Observable 함수를 생성한다. Original Observable에 적용된 결과를 Merge하여 내보낸다. 값을 변환하는 중 새로운 값이 앞으로 끼어들 수 있.. 2023. 7. 26. 이전 1 다음 반응형
