RxJava란? RxJava란 넷플릭스에서 만든 Reactive Programming 라이브러리이며 ReactiveX라이브러리의 JVM 구현체이다.
Observable의 사전 뜻을 찾아보면 관찰할 수 있는, 식별 가능한 이러한 의미를 가지고 있다. 즉, Observable은 데이터의 흐름에 맞게 알림을 보내 observable을 구독하는 Observer가 데이터를 사용할 수 있도록 한다.
Observable에는 Cold Observable과 Hot Observable이 있다. 일반적으로 우리가 사용하는 것들은 모두 Cold Observable이라고 한다.
RxJava에 대한 연산자에 대한 기본적인 이해와 변환 연산자에 대해 자세히 알아보았다.
RxJava에서 제어 연산자란 입력 데이터 중 원하는 데이터를 골라내는 함수이다. filter(), first(), take() 등이 있다.
결합 연산자는 다수의 Observable을 하나로 합치는 방법을 제공한다. flatMap(), groupBy() 함수 등은 1개의 Observable을 확장해주는 반면 결합 연산자들은 여러 개의 Observable을 내가 원하는 Observable로 결합해준다.
조건 연산자는 Observable 객체 내 데이터의 흐름을 제어하는 연산자이다.
RxJava에서의 Scheduler는 RxJava 비동기 프로그래밍을 위한 쓰레드 관리자이다.즉, 스케쥴러를 이용해서 어떤 쓰레드에서 무엇을 처리할 지에 대해서 제어할 수 있다.