@ElementsAreNonnullByDefault package io.servicetalk.concurrent
ServiceTalk concurrent common types.
ClassDescriptionAn entity that can be cancelled.An asynchronous computation that does not emit any data.Subscriber of the outcome of a
Cancellable.A general abstraction to execute immediate and delayed tasks.An extension of
AutoCloseableto add graceful closure semantics.An asynchronous computation that emits zero or more items to its
PublisherSource.Subscriberand may or may not terminate successfully or with an error.A subscriber of result(s) produced by a
PublisherSource.SingleSource<T>An asynchronous computation that either completes with success giving the result or completes with an error.Subscriber of the outcome of a
SingleSource.A source of time that can be represented as a