@Test public void asyncFilter() { Flux<Integer> flux = workshop.asyncComputedFilter(Flux.just(1, 2, 3, 4, 5)); StepVerifier.create(flux) .expectNext(2, 4) .verifyComplete(); }
Mono<Boolean> asyncFilter(Integer integer) { return Mono.just(integer % 2 == 0).delayElement(Duration.ofMillis(500)); }
Part03Filtering { Mono<Boolean> asyncFilter(Integer integer) { return Mono.just(integer % 2 == 0).delayElement(Duration.ofMillis(500)); } }
Part03Filtering { Mono<Boolean> asyncFilter(Integer integer) { return Mono.just(integer % 2 == 0).delayElement(Duration.ofMillis(500)); }  }
Part03Filtering { Mono<Boolean> asyncFilter(Integer integer) { return Mono.just(integer % 2 == 0).delayElement(Duration.ofMillis(500)); }   }
Part03Filtering { Mono<Boolean> asyncFilter(Integer integer) { return Mono.just(integer % 2 == 0).delayElement(Duration.ofMillis(500)); }    }