io.servicetalk.concurrent

Interface Summary
Interface	Description
BlockingIterable<T>	An `Iterable` which supports generation of `BlockingIterator`s.
BlockingIterable.Processor<T>	A `BlockingIterable` that supports to dynamically emitting items using `BlockingIterable.Processor.next(Object)`.
BlockingIterator<T>	An `Iterator` that is also an `AutoCloseable` and whose blocking operations support timeout durations.
BlockingSpliterator<T>	An `Spliterator` which supports `AutoCloseable.close()`.
Cancellable	An entity that can be cancelled.
CloseableIterable<T>	An `Iterable` which supports generation of `CloseableIterator`s.
CloseableIterator<T>	An `Iterator` that is also an `AutoCloseable`.
CompletableSource	An asynchronous computation that does not emit any data.
CompletableSource.Processor	A `CompletableSource.Processor` represents a processing stage that is both a `CompletableSource` and a `CompletableSource.Subscriber` and obeys the contracts of both.
CompletableSource.Subscriber	Subscriber of the outcome of a `Cancellable`.
Executor	A general abstraction to execute immediate and delayed tasks.
GracefulAutoCloseable	An extension of `AutoCloseable` to add graceful closure semantics.
PublisherSource<T>	An asynchronous computation that emits zero or more items to its `PublisherSource.Subscriber` and may or may not terminate successfully or with an error.
PublisherSource.Subscriber<T>	A subscriber of result(s) produced by a `PublisherSource`.
PublisherSource.Subscription	A subscription to control the signals emitted from a `PublisherSource` to a `PublisherSource.Subscriber`.
SingleSource<T>	An asynchronous computation that either completes with success giving the result or completes with an error.
SingleSource.Processor<T,R>	A `SingleSource.Processor` represents a processing stage that is both a `SingleSource` and a `SingleSource.Subscriber` and obeys the contracts of both.
SingleSource.Subscriber<T>	Subscriber of the outcome of a `SingleSource`.

Package io.servicetalk.concurrent