Package io.servicetalk.concurrent

@ElementsAreNonnullByDefault package io.servicetalk.concurrent

ServiceTalk concurrent common types.

Related Packages

Package	Description
io.servicetalk.concurrent.api	ServiceTalk concurrent APIs which follow Reactive Streams semantics.
io.servicetalk.concurrent.internal	Internal utilities used by concurrent packages.
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.

Interfaces

Class	Description
BlockingIterable<T>	An Iterable which supports generation of BlockingIterators.
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 CloseableIterators.
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.Processor<T,R>	A PublisherSource.Processor represents a processing stage that is both a PublisherSource and a PublisherSource.Subscriber and obeys the contracts of both.
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.
TimeSource	A source of time that can be represented as a long.