Reference Reference

Take

• Sequence 필터링 Operator

  Spring Reactive Web Application/Project Reactor 2023. 8. 4. 05:00

  filter filter() Operator는 Upstream에서 emit된 데이터 중 조건에 일치하는 데이터만 Downstream으로 emit 합니다. 즉, 파라미터로 입력받은 Predicate의 리턴 값이 true인 데이터만 Downstream으로 emit 합니다. import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Flux; /** * filter 예제 */ @Slf4j public class Example14_15 { public static void main(String[] args) { Flux .range(1, 20) .filter(num -> num % 2 != 0) .subscribe(data -> log.info("# onN..

  Read More
• 필터링 연산자

  BackEnd/RxJava 2023. 7. 6. 07:00

  filter 전달 받은 데이터가 조건에 맞는지 확인한 후 결과가 true인 데이터만 통지합니다. 파라미터로 받는 Predicate 함수형 인터페이스에서 조건을 확인합니다. 연산자 함수는 메서드 체인으로 여러 개를 사용할 수 있습니다. package com.itvillage.chapter05.chapter0502; import com.itvillage.common.CarMaker; import com.itvillage.common.SampleData; import io.reactivex.Observable; public class ObservableFilterExample02 { public static void main(String[] args) { Observable.fromIterable(Sample..

  Read More