Package io.servicetalk.concurrent.internal

@ElementsAreNonnullByDefault package io.servicetalk.concurrent.internal

Internal utilities used by concurrent packages.

Related Packages

Package	Description
io.servicetalk.concurrent	ServiceTalk concurrent common types.
io.servicetalk.concurrent.api	ServiceTalk concurrent APIs which follow Reactive Streams semantics.
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
AbstractCloseableIterable<T>	An abstract implementation of CloseableIterable that wraps an Iterable.
AbstractCloseableIteratorAsInputStream<T>	Conversion from a CloseableIterator to a InputStream given a Function to serialize to bytes.
ArrayUtils	Deprecated. This internal class will be removed in the future releases without a replacement.
AutoClosableUtils	Utilities for AutoCloseable.
BlockingIterables	Utility methods for BlockingIterable.
CancelImmediatelySubscriber	A PublisherSource.Subscriber that invokes Cancellable.cancel() in PublisherSource.Subscriber.onSubscribe(Subscription).
ConcurrentSubscription	This class prevents concurrent invocation of PublisherSource.Subscription methods and preserves the Reactive Streams, 2.7 rule when there is a possibility of concurrency.
ConcurrentTerminalSubscriber<T>	Deprecated. This internal class will be removed in the future releases without a replacement.
ConcurrentUtils	Utilities which can be used for concurrency.
ContextMapUtils	Shared utilities for ContextMap.
DefaultContextMap	Default implementation of ContextMap.
DelayedCancellable	A Cancellable which serves as a placeholder until the "real" Cancellable is available.
DelayedSubscription	A PublisherSource.Subscription which serves as a placeholder until the "real" PublisherSource.Subscription is available.
DuplicateSubscribeException	Used in scenarios where a subscribe to an asynchronous source is subscribed to, but there is already a subscriber and the source doesn't support multiple subscribers.
EmptySubscriptions	Utility methods for PublisherSource.Subscriptions which don't deliver any data.
FlowControlUtils	A set of utility methods for safe math operations to prevent overflow.
FutureUtils	A set of utilities for interacting with Future.
LatestValueSubscriber<T>	Deprecated. This class is no longer used by ServiceTalk and will be removed in the future releases.
QueueFullAndRejectedSubscribeException	Deprecated. This class is no longer used by ServiceTalk and will be removed in the future releases.
QueueFullException	Exception indicating a bounded queue is full.
RejectedSubscribeError	Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is established.
RejectedSubscribeException	Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is established.
ScalarValueSubscription<T>	A PublisherSource.Subscription that only emits a single value.
SequentialCancellable	A Cancellable that can hold at most one Cancellable that will be cancelled when this is cancelled.
SubscriberUtils	A set of utilities for common PublisherSource.Subscriber tasks.
TerminalNotification	Holder of Throwable.
ThreadInterruptingCancellable	A Cancellable that will interrupt a thread.
ThrowableUtils	Utility for creating static Throwables.