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`.
ConcurrentSubscription	Wraps another `PublisherSource.Subscription` and guards against multiple calls of `Cancellable.cancel()`.
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.
EmptySubscription	A `PublisherSource.Subscription` implementation, which does not do anything.
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.
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
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