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 . |