Flux - Learn to write Junit Tests - Build Reactive API Using Spring Boot/Spring WebFlux

In this video, we will learn about how to write Junits for the Flux reactive type.

[vinayaknp]

Very well explained . You go into lots of details to cover concepts. This tutorial should certainly be more popular.

[parimisiva]

Thanks lot ..you explained well and helped me to understand well on reactive

[feezankhattak]

We can also test the class by not even specify error class and message as;

@Test
public void fluxTest12(){
Flux<String> flux = Flux.just("Spring boot", "Reactive Spring boot")
.concatWith(Flux.error(new RuntimeException("Run time Exception")))
.log();

StepVerifier.create(flux)
.expectNextCount(2)
.verifyError();
}

[ankitachavan]

what if we directly write Occured ! ") instead of
Occured ! ").verify();
is there any change in working ?

[swathich]

what shortcut do you use for zoom in the code?

[AbhishekChanda]

When you use stringFlux.subscribe(..), who is the subscriber of that flux?