- 연산자는 메서드(함수)이다.
- 연산자를 이용하여 데이터를 생성하고 통지하는 Flowable이나 Observable 등의 생산자를 생성할 수 있다.
- 통지한 데이터를 다양한 연산자를 사용하여 가공 처리해 결과값을 만들어 낸다.
연산자
Flowable/Observable 생성 연산자
- interval
- 지정한 시간 간격마다 0부터 시작하는 숫자(Long)를 통지
- 완료 없이 계속 통지
- 호출한 스레드와는 별도의 스레드에서 실행
- range
- timer
- 호출한 스레드와는 별도의 스레드에서 실행
- 특정 시간을 대기한 후에 어떤 처리를 하고자 할 때 활용
- defer
- 데이터 흐름의 생성을 지연하는 효과를 보여준다.
- 최신의 데이터를 얻을 때 사용
- fromIterable
- fromFuture
통지된 데이터를 필터링 해주는 연산자
소비하는 쪽에서 데이터를 필터링한다.
- filter
- distinct
- take
- 파라미터로 지정한 개수나 기간이 될 때까지 데이터를 통지한다.
- 지정한 범위가 통지 데이터보다 클 경우 데이터를 모두 통지하고 완료한다.
- takeUnitl
- skip
통지된 데이터를 변환해주는 연산자