Package org.eclipse.microprofile.reactive.streams.operators.spi
package org.eclipse.microprofile.reactive.streams.operators.spi
-
ClassDescriptionA graph.An engine for turning reactive streams graphs into Reactive Streams publishers/subscribers.This class is not intended to be used by end-users but for portable container integration purpose only.A stage of a Reactive Streams graph.A cancelling stage.A collect stage.Concatenate the given graphs together.A stage that couples a wrapped subscriber graph to a wrapped publisher graph.A stage returning a stream consisting of the distinct elements (according to
Object.equals(Object)) of this stream.A drop while stage.A failed publisher.A filter stage.A subscriber stage that emits the first element encountered.A flat map stage.A flat map stage that emits and flattensCompletionStage.A flat map stage that emits and fattensIterable.A publisher representation of aCompletionStage.A publisher representation of aCompletionStage.A limit stage.A map stage.A publisher of zero to many values.A stage returning a stream containing all the elements from this stream, additionally performing the provided action when this stream completes.A stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream conveys an error.A stage to handle errors from upstream.A stage to handle errors from upstream.A stage returning a stream containing all the elements from this stream, additionally performing the provided action if this stream terminates with an error, completes, or is cancelled by downstream.A stage returning a stream containing all the elements from this stream, additionally performing the provided action on each element.A processor stage.A publisher stage.A skip stage.A subscriber.A take while stage.A subscriber and completion stage pair.All instances ofPublisherBuilder,ProcessorBuilder,SubscriberBuilderandCompletionRunnermust implement this, to ensure that the builder can be turned into a graph by other implementations of the API.Exception thrown when a reactive streams engine doesn't support a stage that is passed to it.