Package io.servicetalk.concurrent.test.internal

@ElementsAreNonnullByDefault package io.servicetalk.concurrent.test.internal

Internal concurrent test utilities used by ServiceTalk.

Classes

Class	Description
AwaitUtils	Utilities to do blocking await calls for tests.
TestCompletableSubscriber	A CompletableSource.Subscriber that enqueues signals and provides blocking methods to consume them.
TestPublisherSubscriber<T>	A PublisherSource.Subscriber that enqueues TestPublisherSubscriber.onNext(Object) and terminal signals while providing blocking methods to consume these events.
TestSingleSubscriber<T>	A SingleSource.Subscriber that enqueues signals and provides blocking methods to consume them.