Interface Summary 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
ProducesResult<T>A stream that completes with a single result. PublisherBuilder<T>A builder for a
ReactiveStreamsFactoryFactory interface for providing the implementation of the static factory methods in
SubscriberBuilder<T,R>A builder for a
Subscriberand its result.
TransformingOperators<T>Operations for transforming a stream.
Class Summary Class Description ReactiveStreamsPrimary entry point into the Reactive Streams utility API.