• 연산자는 메서드(함수)이다.
• 연산자를 이용하여 데이터를 생성하고 통지하는 Flowable이나 Observable 등의 생산자를 생성할 수 있다.
• 통지한 데이터를 다양한 연산자를 사용하여 가공 처리해 결과값을 만들어 낸다.

연산자

Flowable/Observable 생성 연산자

• interval
  • 지정한 시간 간격마다 0부터 시작하는 숫자(Long)를 통지
  • 완료 없이 계속 통지
  • 호출한 스레드와는 별도의 스레드에서 실행
• range
  • for, while을 대체
• timer
  • 호출한 스레드와는 별도의 스레드에서 실행
  • 특정 시간을 대기한 후에 어떤 처리를 하고자 할 때 활용
• defer
  • 데이터 흐름의 생성을 지연하는 효과를 보여준다.
  • 최신의 데이터를 얻을 때 사용
• fromIterable
  • Iterable을 받아서 생성한다
• fromFuture

통지된 데이터를 필터링 해주는 연산자

소비하는 쪽에서 데이터를 필터링한다.

• filter
• distinct
• take
  • 파라미터로 지정한 개수나 기간이 될 때까지 데이터를 통지한다.
  • 지정한 범위가 통지 데이터보다 클 경우 데이터를 모두 통지하고 완료한다.
• takeUnitl
  • take에서 조건을 추가
• skip

통지된 데이터를 변환해주는 연산자