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.