I tried to use UniAssertSubscriber in test, but it is not powerful as reactor's StepVerifier.
I hope there are some fluent APIs added to UniAssertSubscriber like this to assert the items or exception directly.
assertItem(Matcher<T>)/assertNull()/assertEmpty()
consumeWith(Consumer<T>)
For Multi subscriber.
assertNextItem(Matcher<T>)
assertNextNItem(Long n, Matcher<List<T>> or Matcher<T>...)
assertNextCount(Long)
consumeNextWith(Consumer<T>)
consumeNextNWith(Long n, Consumer<List<T>>)
// and send cancel signal and verify