BlockingIterable<T> |
|
BlockingIterable.Processor<T> |
|
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> |
|
CloseableIterator<T> |
An Iterator that is also an AutoCloseable .
|
CompletableSource |
An asynchronous computation that does not emit any data.
|
CompletableSource.Processor |
|
CompletableSource.Subscriber |
|
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> |
|
PublisherSource.Subscriber<T> |
A subscriber of result(s) produced by a PublisherSource .
|
PublisherSource.Subscription |
|
SingleSource<T> |
An asynchronous computation that either completes with success giving the result or completes with an error.
|
SingleSource.Processor<T,R> |
|
SingleSource.Subscriber<T> |
|