### Question:
Part05Subscribe { public Flux<Integer> subscribeWithSubscriptionConsumer() { Flux<Integer> flux = Flux.just(1, 2, 3); flux.log().subscribe(null, null, null, new Consumer<Subscription>() { @Override public void accept(Subscription subscription) { subscription.request(2); } }); return flux; }  Flux<Integer> subscribeEmpty(); Flux<Integer> subscribeWithConsumer(); Flux<Integer> subscribeWithConsumerAndCompleteConsumer(); Flux<Integer> subscribeWithConsumerAndErrorConsumer(); Flux<Integer> subscribeWithSubscriptionConsumer(); Flux<Integer> subscribeWithSubscription();  }### Answer:
@Test public void subscribeWithSubscriptionConsumer() { Flux<Integer> flux = workshop.subscribeWithSubscriptionConsumer(); StepVerifier.create(flux) .expectNext(1, 2, 3).verifyComplete(); }