Package io.servicetalk.concurrent.test.internal
@ElementsAreNonnullByDefault
package io.servicetalk.concurrent.test.internal
Internal concurrent test utilities used by ServiceTalk.
-
ClassesClassDescriptionUtilities to do blocking await calls for tests.A
CompletableSource.Subscriber
that enqueues signals and provides blocking methods to consume them.APublisherSource.Subscriber
that enqueuesTestPublisherSubscriber.onNext(Object)
and terminal signals while providing blocking methods to consume these events.ASingleSource.Subscriber
that enqueues signals and provides blocking methods to consume them.