| Interface | Description |
|---|---|
| CompletionRunner<T> |
A builder for a closed reactive streams graph.
|
| CompletionSubscriber<T,R> |
A subscriber that redeems a completion stage when it completes.
|
| ConnectingOperators<T> |
Operators for connecting different graphs together.
|
| ConsumingOperators<T> |
Operators for completing a stream.
|
| ErrorHandlingOperators<T> |
Operators for handling errors in streams.
|
| FilteringOperators<T> |
Operations for transforming a stream.
|
| PeekingOperators<T> |
Operations for peeking at elements and signals in the stream, without impacting the stream itself.
|
| ProcessorBuilder<T,R> |
A builder for a
Processor. |
| ProducesResult<T> |
A stream that completes with a single result.
|
| PublisherBuilder<T> |
A builder for a
Publisher. |
| ReactiveStreamsFactory |
Factory interface for providing the implementation of the static factory methods in
ReactiveStreams. |
| SubscriberBuilder<T,R> |
A builder for a
Subscriber and its result. |
| TransformingOperators<T> |
Operations for transforming a stream.
|
| Class | Description |
|---|---|
| ReactiveStreams |
Primary entry point into the Reactive Streams utility API.
|
Copyright © 2019 Eclipse Foundation. All rights reserved.