@Test public void ignoreDuplicates() { Flux<Integer> flux = workshop.ignoreDuplicates(Flux.just(1, 1, 2, 2, 3, 4)); StepVerifier.create(flux) .expectNext(1, 2, 3, 4) .verifyComplete(); }
Flux<Integer> ignoreDuplicates(Flux<Integer> flux) { return flux.distinct().log(); }
Part03Filtering { Flux<Integer> ignoreDuplicates(Flux<Integer> flux) { return flux.distinct().log(); } }
Part03Filtering { Flux<Integer> ignoreDuplicates(Flux<Integer> flux) { return flux.distinct().log(); }  }
Part03Filtering { Flux<Integer> ignoreDuplicates(Flux<Integer> flux) { return flux.distinct().log(); }   }
Part03Filtering { Flux<Integer> ignoreDuplicates(Flux<Integer> flux) { return flux.distinct().log(); }    }