io.servicetalk.concurrent.internal

Interface Summary
Interface	Description
RejectedSubscribeError	Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is established.
SignalOffloader	A contract to offload signals to and from any asynchronous source.
SignalOffloaderFactory	A factory to create new instances of `SignalOffloader`.

Class Summary
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	Utilities for arrays.
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>	A `PublisherSource.Subscriber` that allows for concurrent delivery of terminal events.
ConcurrentUtils	Utilities which can be used for concurrency.
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.
DelegatingSignalOffloader	A `SignalOffloader` that delegates all calls to another `SignalOffloader`.
DelegatingSignalOffloaderFactory	A `SignalOffloaderFactory` that delegates all calls to another `SignalOffloaderFactory`.
EmptySubscriptions	Utility methods for `PublisherSource.Subscription`s 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>	A `PublisherSource.Subscriber` which makes the latest value from `LatestValueSubscriber.onNext(Object)` available outside the context of the `PublisherSource.Subscriber`.
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.
ServiceTalkTestTimeout	Standard timeout shared by test classes.
SignalOffloaders	A factory for creating different `SignalOffloader`s.
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 `Throwable`s.

Exception Summary
Exception	Description
DeliberateException
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.
QueueFullAndRejectedSubscribeException	Exception indicating a bounded queue is full, which also resulted in a rejected subscribe.
QueueFullException	Exception indicating a bounded queue is full.
RejectedSubscribeException	Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is established.

Package io.servicetalk.concurrent.internal