Package io.servicetalk.concurrent.api

@ElementsAreNonnullByDefault package io.servicetalk.concurrent.api

ServiceTalk concurrent APIs which follow Reactive Streams semantics.

Related Packages

Package	Description
io.servicetalk.concurrent	ServiceTalk concurrent common types.
io.servicetalk.concurrent.api.internal	Internal utilities which leverage the concurrent API package.
io.servicetalk.concurrent.api.test	Utilities that help build tests when interacting with ServiceTalk concurrent APIs.
io.servicetalk.concurrent.internal	Internal utilities used by concurrent packages.
io.servicetalk.concurrent.jdkflow	Adapters between ServiceTalk's concurrency APIs and the JDK's Flow API.
io.servicetalk.concurrent.reactivestreams	Adapters between Reactive Streams Publisher and ServiceTalk concurrent APIs.

Class	Description
AsyncCloseable	Used to close/shutdown a resource.
AsyncCloseables	A utility class to create AsyncCloseables.
AsyncCloseables.CloseableResource	A resource that can be converted to an AsyncCloseable.
AsyncContext	Presents a static interface to retain state in an asynchronous environment.
AutoCloseables	A utility class for methods related to AutoCloseable.
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.
BufferStrategies	A static factory of BufferStrategy instances.
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.
ByteArrayMapper<T>	A mapper to transform byte[] buffer regions into a desired type T.
Completable	An asynchronous computation that does not emit any data.
CompletableOperator	An operator contract for a Completable.
CompositeCloseable	A AsyncCloseable and Closeable that allows for adding new AsyncCloseables till it is closed.
DefaultThreadFactory	A ThreadFactory implementation.
DelegatingExecutor	An Executor that simply delegates all calls to another Executor.
Executor	A general abstraction to execute immediate and delayed tasks.
Executors	Utility methods to create various Executors.
Function3<T1,T2,T3,R>	A functional interface that accepts 3 arguments and generates a return value.
Function4<T1,T2,T3,T4,R>	A functional interface that accepts 4 arguments and generates a return value.
GroupedPublisher<Key,T>	A group as emitted by Publisher.groupBy(Function, int) or its variants.
GroupedPublisher.QueueSizeProvider	Deprecated. Use Publisher.groupBy(Function, int) instead.
ListenableAsyncCloseable	Provides a way to subscribe when AsyncCloseable.closeAsync() is completed.
LongBinaryConsumer	A special consumer that takes two long arguments.
Processors	Static factory methods for creating processor instances for different type of sources.
ProcessorSignalsConsumer<T>	Consumer of items from a PublisherProcessorSignalsHolder or BlockingProcessorSignalsHolder.
Publisher<T>	An asynchronous computation that produces 0, 1 or more elements and may or may not terminate successfully or with an error.
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.
RepeatStrategies	A set of strategies to use for repeating with Publisher.repeatWhen(IntFunction), Single.repeatWhen(IntFunction) and Completable.repeatWhen(IntFunction) or in general.
RepeatStrategies.TerminateRepeatException	An Exception instance used to indicate termination of repeats.
ReplayAccumulator<T>	Accumulates signals for the Publisher replay operator.
ReplayStrategies	Utilities to customize ReplayStrategy.
ReplayStrategy<T>	Used to customize the strategy for the Publisher replay operator.
ReplayStrategyBuilder<T>	A builder of ReplayStrategy.
RetryStrategies	A set of strategies to use for retrying with Publisher.retryWhen(BiIntFunction), Single.retryWhen(BiIntFunction), and Completable.retryWhen(BiIntFunction) or in general.
ScanLifetimeMapper<T,R>	Provides the ability to transform (aka map) signals emitted via the Publisher.scanWithLifetimeMapper(Supplier) operator, as well as the ability to cleanup state via ScanLifetimeMapper.afterFinally().
ScanMapper<T,R>	Provides the ability to transform (aka map) signals emitted via the Publisher.scanWithMapper(Supplier) operator.
ScanMapper.MappedTerminal<R>	Result of a mapping operation of a terminal signal.
ScanWithLifetimeMapper<T,R>	Deprecated. Use ScanLifetimeMapper.
ScanWithMapper<T,R>	Deprecated. Use ScanMapper.
Single<T>	An asynchronous computation that either completes with success giving the result or completes with an error.
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.
SourceAdapters	A set of adapter methods to convert an asynchronous source in this module to a corresponding source in io.servicetalk.concurrent module.
SwitchMapSignal<T>	A signal containing the data from a series of Publishers switched in a serial fashion.
TerminalSignalConsumer	A contract that provides discrete callbacks for various ways in which a PublisherSource.Subscriber or a CompletableSource.Subscriber can terminate.
TriConsumer<X,Y,Z>	Represents an operation that accepts three input arguments and returns no result.