ReservationClient { public Flux<Reservation> getAllReservations() { return this .client .get() .uri("http: .retrieve() .bodyToFlux( Reservation.class); } ReservationClient(WebClient client); Flux<Reservation> getAllReservations();  }
@Test public void getAllReservations() throws Exception { StepVerifier .create(this.client.getAllReservations()) .expectNext(this.one, this.two) .verifyComplete(); }