@Test public void transform() { Flux<Integer> flux = workshop.transformToLength(Flux.just("foo", "bar")); StepVerifier.create(flux).expectNext(3, 3).verifyComplete(); }
Flux<Integer> transformToLength(Flux<String> flux) { return flux.map(s -> s.length()); }
Part02Transform { Flux<Integer> transformToLength(Flux<String> flux) { return flux.map(s -> s.length()); } }
Part02Transform { Flux<Integer> transformToLength(Flux<String> flux) { return flux.map(s -> s.length()); }  }
Part02Transform { Flux<Integer> transformToLength(Flux<String> flux) { return flux.map(s -> s.length()); }  Flux<Tuple2<String, Integer>> pairValues(Flux<String> flux1, Flux<Integer> flux2); Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress); }
Part02Transform { Flux<Integer> transformToLength(Flux<String> flux) { return flux.map(s -> s.length()); }  Flux<Tuple2<String, Integer>> pairValues(Flux<String> flux1, Flux<Integer> flux2); Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress);  }