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.
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.
PublisherOperator<T,R>	An operator contract for a `Publisher`.
PublisherToSingleOperator<T,R>	An operator contract for a `Publisher` to `Single` conversion.
SingleOperator<T,R>	An operator contract for a `Single`.
TerminalSignalConsumer	Callback interface on which only a single method is ever called matching the terminal outcome of the associated `Source` and `Subscription`.

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`.
Completable	An asynchronous computation that does not emit any data.
DefaultThreadFactory	A `ThreadFactory` implementation.
DelegatingExecutor	An `Executor` that simply delegates all calls to another `Executor`.
Executors	Utility methods to create various `Executor`s.
GroupedPublisher<Key,T>	A group as emitted by `Publisher.groupBy(Function, int)` or its variants.
Processors	Utility class for `SingleSource.Processor` and `CompletableSource.Processor`.
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.
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.

Exception Summary
Exception Description

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

Package io.servicetalk.concurrent.api