@Test public void combineValues() { Mono<String> phoneNumber = Mono.just("076123456"); Mono<String> deliveryAddress = Mono.just("Paradeplatz Zurich"); Mono<Order> order = workshop.combineValues(phoneNumber, deliveryAddress); StepVerifier.create(order).expectNext(new Order("076123456", "Paradeplatz Zurich")); order = workshop.combineValues(Mono.empty(), deliveryAddress); StepVerifier.create(order).verifyComplete(); order = workshop.combineValues(Mono.error(new RuntimeException()), deliveryAddress); StepVerifier.create(order).verifyError(); }
public Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress) { return Mono.zip(phoneNumber, deliveryAddress, (p, d) -> new Order(p, d)); }
Part02Transform { public Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress) { return Mono.zip(phoneNumber, deliveryAddress, (p, d) -> new Order(p, d)); } }
Part02Transform { public Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress) { return Mono.zip(phoneNumber, deliveryAddress, (p, d) -> new Order(p, d)); }  }
Part02Transform { public Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress) { return Mono.zip(phoneNumber, deliveryAddress, (p, d) -> new Order(p, d)); }  Flux<Tuple2<String, Integer>> pairValues(Flux<String> flux1, Flux<Integer> flux2); Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress); }
Part02Transform { public Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress) { return Mono.zip(phoneNumber, deliveryAddress, (p, d) -> new Order(p, d)); }  Flux<Tuple2<String, Integer>> pairValues(Flux<String> flux1, Flux<Integer> flux2); Mono<Order> combineValues(Mono<String> phoneNumber, Mono<String> deliveryAddress);  }