Package org.eclipse.microprofile.reactive.streams.operators
package org.eclipse.microprofile.reactive.streams.operators
-
ClassDescriptionA builder for a closed reactive streams graph.CompletionSubscriber<T,
R> A subscriber that redeems a completion stage when it completes.Operators for connecting different graphs together.Operators for completing a stream.Operators for handling errors in streams.Operations for transforming a stream.Operations for peeking at elements and signals in the stream, without impacting the stream itself.ProcessorBuilder<T,R> A builder for aProcessor
.A stream that completes with a single result.A builder for aPublisher
.Primary entry point into the Reactive Streams utility API.Factory interface for providing the implementation of the static factory methods inReactiveStreams
.SubscriberBuilder<T,R> A builder for aSubscriber
and its result.Operations for transforming a stream.