@Test public void filterEven() { Flux<Integer> flux = workshop.filterEven(Flux.just(1, 2, 3, 4, 5)); StepVerifier.create(flux) .expectNext(2, 4) .verifyComplete(); }
Flux<Integer> filterEven(Flux<Integer> flux) { return flux.filter(i -> i % 2 == 0).log(); }
Part03Filtering { Flux<Integer> filterEven(Flux<Integer> flux) { return flux.filter(i -> i % 2 == 0).log(); } }
Part03Filtering { Flux<Integer> filterEven(Flux<Integer> flux) { return flux.filter(i -> i % 2 == 0).log(); }  }
Part03Filtering { Flux<Integer> filterEven(Flux<Integer> flux) { return flux.filter(i -> i % 2 == 0).log(); }   }
Part03Filtering { Flux<Integer> filterEven(Flux<Integer> flux) { return flux.filter(i -> i % 2 == 0).log(); }    }