Package io.servicetalk.concurrent.api
-
Interface Summary Interface Description AsyncCloseable Used to close/shutdown a resource.AsyncCloseables.CloseableResource A resource that can be converted to anAsyncCloseable
.AsyncContextMap The key-value map stored in theAsyncContext
.AsyncContextMapHolder Interface for setting and getting aAsyncContextMap
.BiIntFunction<T,R> A special function that takes anint
and a custom argument and returns the result.BiIntPredicate<T> A special predicate that takes anint
and a custom argument to evaluate.BlockingProcessorSignalsHolder<T> A holder of items for aBlockingIterable.Processor
.BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B> BufferStrategy.Accumulator<T,B> An intermediate mutable object that holds items till it isfinished
.CompletableOperator An operator contract for aCompletable
.CompositeCloseable Executor A general abstraction to execute immediate and delayed tasks.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.QueueSizeProvider Provide the maximum queue size to use for a particularGroupedPublisher
key.ListenableAsyncCloseable Provides a way to subscribe whenAsyncCloseable.closeAsync()
is completed.ProcessorSignalsConsumer<T> Consumer of items from aPublisherProcessorSignalsHolder
orBlockingProcessorSignalsHolder
.PublisherOperator<T,R> An operator contract for aPublisher
.PublisherProcessorSignalsHolder<T> A holder of items for aPublisherSource.Processor
.PublisherToSingleOperator<T,R> ScanWithLifetimeMapper<T,R> Provides the ability to transform (aka map) signals emitted via thePublisher.scanWithLifetime(Supplier)
operator, as well as the ability to cleanup state viaScanWithLifetimeMapper.afterFinally()
.ScanWithMapper<T,R> Provides the ability to transform (aka map) signals emitted via thePublisher.scanWith(Supplier)
operator.SingleOperator<T,R> An operator contract for aSingle
.SingleTerminalSignalConsumer<T> A contract that provides discrete callbacks for various ways in which aSingleSource.Subscriber
can terminate.TerminalSignalConsumer A contract that provides discrete callbacks for various ways in which aPublisherSource.Subscriber
or aCompletableSource.Subscriber
can terminate. -
Class Summary Class Description AsyncCloseables A utility class to createAsyncCloseable
s.AsyncContext Presents a static interface to retain state in an asynchronous environment.AsyncContextMap.Key<T> A key identifies a specific object in aAsyncContextMap
.AutoCloseables A utility class for methods related toAutoCloseable
.AutoOnSubscribeCompletableSubscriberFunction CallsCompletableSource.Subscriber.onSubscribe(Cancellable)
automatically, sending a delegatingCancellable
.AutoOnSubscribePublisherSubscriberFunction<T> CallsPublisherSource.Subscriber.onSubscribe(Subscription)
automatically, sending a delegatingPublisherSource.Subscription
.AutoOnSubscribeSingleSubscriberFunction<T> CallsSingleSource.Subscriber.onSubscribe(Cancellable)
automatically, sending a delegatingCancellable
.BlockingTestUtils Utilities to await results of an asynchronous computation either by blocking the calling thread.BufferStrategies A static factory ofBufferStrategy
instances.Completable An asynchronous computation that does not emit any data.ConcurrentCompletableSubscriberFunction Allows multipleCompletableSource.Subscriber
s to be concurrently subscribed to aTestCompletable
, and multicasts signals to them all.ConcurrentPublisherSubscriberFunction<T> Allows multiplePublisherSource.Subscriber
s to be concurrently subscribed to aTestPublisher
, and multicasts signals to them all.ConcurrentSingleSubscriberFunction<T> Allows multipleSingleSource.Subscriber
s to be concurrently subscribed to aTestSingle
, and multicasts signals to them all.DefaultThreadFactory AThreadFactory
implementation.DeferredEmptySubscription AnPublisherSource.Subscription
that only emits aTerminalNotification
only upon the first call toDeferredEmptySubscription.request(long)
.DelegatingExecutor DemandCheckingSubscriber<T> APublisherSource.Subscriber
that wraps another, and asserts that items are not delivered without sufficient demand.DemandCheckingSubscriberFunction<T> WrapsPublisherSource.Subscriber
s in aDemandCheckingSubscriber
.ExecutorExtension<E extends Executor> AnExtension
wrapper for anExecutor
.ExecutorRule<E extends Executor> AnExternalResource
wrapper for anExecutor
.Executors Utility methods to create variousExecutor
s.GroupedPublisher<Key,T> A group as emitted byPublisher.groupBy(Function, int)
or its variants.LegacyTestCompletable Deprecated. UseTestCompletable
instead.LegacyTestSingle<T> Deprecated. UseTestSingle
instead.LoggingCompletableSubscriber ACompletableSource.Subscriber
that wraps anotherCompletableSource.Subscriber
, logging all signals received by theCompletableSource.Subscriber
, or sent via theCancellable
.LoggingPublisherSubscriber<T> APublisherSource.Subscriber
that wraps anotherPublisherSource.Subscriber
, logging all signals received by thePublisherSource.Subscriber
, or sent via thePublisherSource.Subscription
.LoggingSingleSubscriber<T> ASingleSource.Subscriber
that wraps anotherSingleSource.Subscriber
, logging all signals received by theSingleSource.Subscriber
, or sent via theCancellable
.NonResubscribeableCompletableSubscriberFunction Allows only a singleCompletableSource.Subscriber
to subscribe to aTestCompletable
.NonResubscribeablePublisherSubscriberFunction<T> Allows only a singlePublisherSource.Subscriber
to subscribe to aTestPublisher
.NonResubscribeableSingleSubscriberFunction<T> Allows only a singleSingleSource.Subscriber
to subscribe to aTestSingle
.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 withPublisher.repeatWhen(IntFunction)
,Single.repeatWhen(IntFunction)
andCompletable.repeatWhen(IntFunction)
or in general.RetryStrategies A set of strategies to use for retrying withPublisher.retryWhen(BiIntFunction)
,Single.retryWhen(BiIntFunction)
, andCompletable.retryWhen(BiIntFunction)
or in general.RunnableCompletable SequentialCompletableSubscriberFunction Allows multipleCompletableSource.Subscriber
s to be sequentially subscribed to aTestCompletable
.SequentialPublisherSubscriberFunction<T> Allows multiplePublisherSource.Subscriber
s to be sequentially subscribed to aTestPublisher
.SequentialSingleSubscriberFunction<T> Allows multipleSingleSource.Subscriber
s to be sequentially subscribed to aTestSingle
.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 inio.servicetalk.concurrent
module.TestCancellable ACancellable
that tracks cancellation.TestCompletable ACompletable
&CompletableSource
whose outgoing signals to itsCompletableSource.Subscriber
s can be controlled.TestCompletable.Builder Allows for creatingTestCompletable
s with non-default settings.TestExecutor AnExecutor
implementation that provides methods for controlling execution of queued and schedules tasks, for testing.TestIterableToBlockingIterable<T> TestPublisher<T> APublisher
&PublisherSource
whose outgoing signals to itsPublisherSource.Subscriber
s can be controlled.TestPublisher.Builder<T> Allows for creatingTestPublisher
s with non-default settings.TestSingle<T> TestSingle.Builder<T> Allows for creatingTestSingle
s with non-default settings.TestSubscription APublisherSource.Subscription
that tracks requests and cancellation.VerificationTestUtils -
Exception Summary Exception Description RepeatStrategies.TerminateRepeatException AnException
instance used to indicate termination of repeats.