@Test public void ignoreUntil() { Flux<Integer> flux = workshop.ignoreUntil(Flux.just(1, 3, 15, 5, 10)); StepVerifier.create(flux) .expectNext(15, 5, 10) .verifyComplete(); StepVerifier.create(workshop.ignoreUntil(Flux.just(1, 3, 5))).verifyComplete(); StepVerifier.create(workshop.ignoreUntil(Flux.empty())).verifyComplete(); }
Flux<Integer> ignoreUntil(Flux<Integer> flux) { return flux.skipUntil(integer -> integer > 10).log(); }
Part03Filtering { Flux<Integer> ignoreUntil(Flux<Integer> flux) { return flux.skipUntil(integer -> integer > 10).log(); } }
Part03Filtering { Flux<Integer> ignoreUntil(Flux<Integer> flux) { return flux.skipUntil(integer -> integer > 10).log(); }  }
Part03Filtering { Flux<Integer> ignoreUntil(Flux<Integer> flux) { return flux.skipUntil(integer -> integer > 10).log(); }   }
Part03Filtering { Flux<Integer> ignoreUntil(Flux<Integer> flux) { return flux.skipUntil(integer -> integer > 10).log(); }    }