Package 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 ofSignalOffloader
. -
Class Summary Class Description AbstractCloseableIterable<T> An abstract implementation ofCloseableIterable
that wraps anIterable
.AbstractCloseableIteratorAsInputStream<T> ArrayUtils Utilities for arrays.AutoClosableUtils Utilities forAutoCloseable
.BlockingIterables Utility methods forBlockingIterable
.CancelImmediatelySubscriber ConcurrentSubscription This class prevents concurrent invocation ofPublisherSource.Subscription
methods and preserves the Reactive Streams, 2.7 rule when there is a possibility of concurrency.ConcurrentTerminalSubscriber<T> APublisherSource.Subscriber
that allows for concurrent delivery of terminal events.ConcurrentUtils Utilities which can be used for concurrency.DelayedCancellable ACancellable
which serves as a placeholder until the "real"Cancellable
is available.DelayedSubscription APublisherSource.Subscription
which serves as a placeholder until the "real"PublisherSource.Subscription
is available.DelegatingSignalOffloader ASignalOffloader
that delegates all calls to anotherSignalOffloader
.DelegatingSignalOffloaderFactory ASignalOffloaderFactory
that delegates all calls to anotherSignalOffloaderFactory
.EmptySubscriptions Utility methods forPublisherSource.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 withFuture
.LatestValueSubscriber<T> APublisherSource.Subscriber
which makes the latest value fromLatestValueSubscriber.onNext(Object)
available outside the context of thePublisherSource.Subscriber
.ScalarValueSubscription<T> APublisherSource.Subscription
that only emits a single value.SequentialCancellable ACancellable
that can hold at most oneCancellable
that will be cancelled when this is cancelled.ServiceTalkTestTimeout Standard timeout shared by test classes.SignalOffloaders A factory for creating differentSignalOffloader
s.SubscriberUtils A set of utilities for commonPublisherSource.Subscriber
tasks.TerminalNotification Holder ofThrowable
.TestTimeoutConstants ThreadInterruptingCancellable ACancellable
that willinterrupt a thread
.ThrowableUtils Utility for creating staticThrowable
s.TimeoutTracingInfoExtension Junit extension which will print information about all threads if unit test method throwsTimeoutException
. -
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.