io.servicetalk.concurrent.api

Interface Summary
Interface	Description
AsyncCloseable	Used to close/shutdown a resource.
AsyncCloseables.CloseableResource	A resource that can be converted to an `AsyncCloseable`.
AsyncContextMap	The key-value map stored in the `AsyncContext`.
AsyncContextMapHolder	Interface for setting and getting a `AsyncContextMap`.
BiIntFunction<T,R>	A special function that takes an `int` and a custom argument and returns the result.
BiIntPredicate<T>	A special predicate that takes an `int` and a custom argument to evaluate.
BlockingProcessorSignalsHolder<T>	A holder of items for a `BlockingIterable.Processor`.
BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B>	A strategy for `buffering` items emitted from a `Publisher`.
BufferStrategy.Accumulator<T,B>	An intermediate mutable object that holds items till it is `finished`.
CompletableOperator	An operator contract for a `Completable`.
CompositeCloseable	A `AsyncCloseable` and `Closeable` that allows for adding new `AsyncCloseable`s till it is closed.
Executor	A general abstraction to execute immediate and delayed tasks.
GroupedPublisher.QueueSizeProvider	Provide the maximum queue size to use for a particular `GroupedPublisher` key.
ListenableAsyncCloseable	Provides a way to subscribe when `AsyncCloseable.closeAsync()` is completed.
ProcessorSignalsConsumer<T>	Consumer of items from a `PublisherProcessorSignalsHolder` or `BlockingProcessorSignalsHolder`.
PublisherOperator<T,R>	An operator contract for a `Publisher`.
PublisherProcessorSignalsHolder<T>	A holder of items for a `PublisherSource.Processor`.
PublisherToSingleOperator<T,R>	An operator contract for a `Publisher` to `Single` conversion.
ScanWithMapper<T,R>	Provides the ability to transform (aka map) signals emitted via the `Publisher.scanWith(Supplier)` operator.
SingleOperator<T,R>	An operator contract for a `Single`.
SingleTerminalSignalConsumer<T>	A contract that provides discrete callbacks for various ways in which a `SingleSource.Subscriber` can terminate.
TerminalSignalConsumer	A contract that provides discrete callbacks for various ways in which a `PublisherSource.Subscriber` or a `CompletableSource.Subscriber` can terminate.

Class Summary
Class	Description
AsyncCloseables	A utility class to create `AsyncCloseable`s.
AsyncContext	Presents a static interface to retain state in an asynchronous environment.
AsyncContextMap.Key<T>	A key identifies a specific object in a `AsyncContextMap`.
AutoCloseables	A utility class for methods related to `AutoCloseable`.
AutoOnSubscribeCompletableSubscriberFunction	Calls `CompletableSource.Subscriber.onSubscribe(Cancellable)` automatically, sending a delegating `Cancellable`.
AutoOnSubscribePublisherSubscriberFunction<T>	Calls `PublisherSource.Subscriber.onSubscribe(Subscription)` automatically, sending a delegating `PublisherSource.Subscription`.
AutoOnSubscribeSingleSubscriberFunction<T>	Calls `SingleSource.Subscriber.onSubscribe(Cancellable)` automatically, sending a delegating `Cancellable`.
BlockingTestUtils	Utilities to await results of an asynchronous computation either by blocking the calling thread.
BufferStrategies	A static factory of `BufferStrategy` instances.
Completable	An asynchronous computation that does not emit any data.
ConcurrentCompletableSubscriberFunction	Allows multiple `CompletableSource.Subscriber`s to be concurrently subscribed to a `TestCompletable`, and multicasts signals to them all.
ConcurrentPublisherSubscriberFunction<T>	Allows multiple `PublisherSource.Subscriber`s to be concurrently subscribed to a `TestPublisher`, and multicasts signals to them all.
ConcurrentSingleSubscriberFunction<T>	Allows multiple `SingleSource.Subscriber`s to be concurrently subscribed to a `TestSingle`, and multicasts signals to them all.
DefaultThreadFactory	A `ThreadFactory` implementation.
DeferredEmptySubscription	An `PublisherSource.Subscription` that only emits a `TerminalNotification` only upon the first call to `DeferredEmptySubscription.request(long)`.
DelegatingExecutor	An `Executor` that simply delegates all calls to another `Executor`.
DemandCheckingSubscriber<T>	A `PublisherSource.Subscriber` that wraps another, and asserts that items are not delivered without sufficient demand.
DemandCheckingSubscriberFunction<T>	Wraps `PublisherSource.Subscriber`s in a `DemandCheckingSubscriber`.
ExecutorRule<E extends Executor>	An `ExternalResource` wrapper for an `Executor`.
Executors	Utility methods to create various `Executor`s.
GroupedPublisher<Key,T>	A group as emitted by `Publisher.groupBy(Function, int)` or its variants.
LegacyTestCompletable	Deprecated. Use `TestCompletable` instead.
LegacyTestSingle<T>	Deprecated. Use `TestSingle` instead.
LoggingCompletableSubscriber	A `CompletableSource.Subscriber` that wraps another `CompletableSource.Subscriber`, logging all signals received by the `CompletableSource.Subscriber`, or sent via the `Cancellable`.
LoggingPublisherSubscriber<T>	A `PublisherSource.Subscriber` that wraps another `PublisherSource.Subscriber`, logging all signals received by the `PublisherSource.Subscriber`, or sent via the `PublisherSource.Subscription`.
LoggingSingleSubscriber<T>	A `SingleSource.Subscriber` that wraps another `SingleSource.Subscriber`, logging all signals received by the `SingleSource.Subscriber`, or sent via the `Cancellable`.
NonResubscribeableCompletableSubscriberFunction	Allows only a single `CompletableSource.Subscriber` to subscribe to a `TestCompletable`.
NonResubscribeablePublisherSubscriberFunction<T>	Allows only a single `PublisherSource.Subscriber` to subscribe to a `TestPublisher`.
NonResubscribeableSingleSubscriberFunction<T>	Allows only a single `SingleSource.Subscriber` to subscribe to a `TestSingle`.
Processors	Static factory methods for creating processor instances for different type of sources.
Publisher<T>	An asynchronous computation that produces 0, 1 or more elements and may or may not terminate successfully or with an error.
RepeatStrategies	A set of strategies to use for repeating with `Publisher.repeatWhen(IntFunction)`, `Single.repeatWhen(IntFunction)` and `Completable.repeatWhen(IntFunction)` or in general.
RetryStrategies	A set of strategies to use for retrying with `Publisher.retryWhen(BiIntFunction)`, `Single.retryWhen(BiIntFunction)`, and `Completable.retryWhen(BiIntFunction)` or in general.
RunnableCompletable
SequentialCompletableSubscriberFunction	Allows multiple `CompletableSource.Subscriber`s to be sequentially subscribed to a `TestCompletable`.
SequentialPublisherSubscriberFunction<T>	Allows multiple `PublisherSource.Subscriber`s to be sequentially subscribed to a `TestPublisher`.
SequentialSingleSubscriberFunction<T>	Allows multiple `SingleSource.Subscriber`s to be sequentially subscribed to a `TestSingle`.
Single<T>	An asynchronous computation that either completes with success giving the result or completes with an error.
SourceAdapters	A set of adapter methods to convert an asynchronous source in this module to a corresponding source in `io.servicetalk.concurrent` module.
TestCancellable	A `Cancellable` that tracks cancellation.
TestCompletable	A `Completable` & `CompletableSource` whose outgoing signals to its `CompletableSource.Subscriber`s can be controlled.
TestCompletable.Builder	Allows for creating `TestCompletable`s with non-default settings.
TestExecutor	An `Executor` implementation that provides methods for controlling execution of queued and schedules tasks, for testing.
TestIterableToBlockingIterable<T>
TestPublisher<T>	A `Publisher` & `PublisherSource` whose outgoing signals to its `PublisherSource.Subscriber`s can be controlled.
TestPublisher.Builder<T>	Allows for creating `TestPublisher`s with non-default settings.
TestSingle<T>	A `Single` & `SingleSource` whose outgoing signals to its `SingleSource.Subscriber`s can be controlled.
TestSingle.Builder<T>	Allows for creating `TestSingle`s with non-default settings.
TestSubscription	A `PublisherSource.Subscription` that tracks requests and cancellation.
VerificationTestUtils

Exception Summary
Exception Description

RepeatStrategies.TerminateRepeatException
An Exception instance used to indicate termination of repeats.

Package io.servicetalk.concurrent.api