assertj-reactor
AssertJ extensions for Mono and Flux.
Getting started
Assertions extend from AssertJ core so a single import statement is enough to get both standard AssertJ methods as well as the reactive additions:
import static pl.rzrz.assertj.reactor.Assertions.assertThat;
Check for an error signal
Mono<Void> mono = Mono.error(new Exception());
assertThat(mono).sendsError();
Inspect the exception:
Mono<Void> mono = Mono.error(new RuntimeException("oops"));
assertThat(mono).sendsError(error -> {
assertThat(error).isInstanceOf(RuntimeException.class);
assertThat(error).hasMessage("oops");
});
Check successful completion
Mono<Void> mono = Mono.just("this");
assertThat(mono).completes();
Count items
Flux<String> flux = Flux.just("one", "two", "three");
assertThat(flux).emitsCount(3);
Check item emitted
Flux<String> flux = Flux.just("one", "two", "three");
assertThat(flux).emits("two");
Check exactly some items emitted
Flux<String> flux = Flux.just("one", "two", "three");
assertThat(flux).emitsExactly("one", "two", "three");