Open Source Your Knowledge, Become a Contributor
Technology knowledge has to be shared and made accessible for free. Join the movement.
Until now, your solution for each exercise was checked by passing the
defined to a test using a
This class from the
reactor-test artifact is capable of subscribing to any
Flux or an Akka Stream...) and then assert a set of user-defined expectations with
regard to the sequence.
If any event is triggered that doesn't match the current expectation, the
will produce an
You can obtain an instance of
StepVerifier from the static factory
create. It offers a
DSL to set up expectations on the data part and finish with a single terminal expectation
(completion, error, cancellation...).
Note that you must always call the
verify() method or one of the shortcuts that
combine the terminal expectation and verify, like
StepVerifier won't subscribe to your sequence and nothing will be asserted.
Let's verify the sequence passed to the code emits two specific elements and that the
then completes successfully.
Now, let's do the same test but verifying that an exception is propagated at the end.
Let's try to create a
StepVerifier with an expectation on a
Some expectations can work by checking a
Predicate on the next value, or even by consuming
the next value by passing it to an assertion library like
Try these lambda-based versions:
On this next test we will receive a
Flux which takes some time to emit. As you can expect,
the test will take some time to run.
The next one is even worse: it emits 1 element per second, completing only after having emitted 3600 of them!
Since we don't want our tests to run for hours, we need a way to speed that up while still being able to assert the data itself (eliminating the time factor).
StepVerifier comes with a virtual time option: by using
the verifier will temporarily replace default core
Schedulers (the component that define
the execution context in Reactor). All these default
Scheduler are replaced by a single
instance of a
VirtualTimeScheduler, which has a virtual clock that can be manipulated.
In order for the operators to pick up that
Scheduler, you should lazily build your operator
chain inside the lambda passed to
You must then advance time as part of your test scenario, by calling either
expectNoEvent(Duration). The former simply advances the clock, while the later additionally
fails if any unexpected event triggers during the provided duration (note that almost all
the time there will at least be a "subscription" event even though the clock hasn't advanced,
so you should usually put a
.withVirtualTime() if you're
going to use
expectNoEvent right after).
StepVerifier.withVirtualtime(() -> Mono.delay(Duration.ofHours(3))) .expectSubscription() .expectNoEvent(Duration.ofHours(2)) .thenAwait(Duration.ofHours(1)) .expectNextCount(1) .verify();
Let's try that by making a fast test of our hour-long publisher: