[리액티브(Reactive) 프로그래밍] 데이터 필터링 연산자

데이터 필터링 연산자 

filter

출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

• 전달 받은 데이터가 조건에 맞는지 확인한 수, 결과가 true인 데이터만 통지함
• 파라미터로 받는 Predicate 함수형 인터페이스에서 조건을 확인함

distinct 

출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

• 이미 통지된 동일한 데이터가 있다면 이후의 동일한 데이터는 통지하지 않음(중복 값 제거) 

take

출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

• 파라미터로 지정한 개수나 기간이 될때까지만 데이터를 통지함 

takeUntil

• 첫번째 유형
  • 파라미터로 지정한 조건이 true 갈 될 때까지 데이터를 계속 통지함

    

    출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

• 두번쨰 유형 
  • 파라미터로 지정한 Observable이 최초 데이터를 통지할 때까지 데이터를 계속 통지함

    

    출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

skip

• 첫번째 유형
  • 파라미터로 지정한 숫자만큼 데이터를 건너뛴 후 나머지 데이터를 통지함 

    

• 두번쨰 유형 
  • 파라미터로 지정한 시간 동안에는 데이터 통지를 건너뛴 후 지정한 시간 이 후에 나머지 데이터를 통지함

    

 

---

출처 : 인프런 (Kevin의 알기쉬운 RxJava) 

Kevin의 알기 쉬운 RxJava 1부 강의 | Kevin - 인프런