All Classes
-
All Classes Interface Summary Class Summary Enum Summary Class Description AdaptersToFlow Adapters from Reactive Streams types toFlow
types.AdaptersToReactiveStreams Adapters fromFlow
types to Reactive Streams types.AsyncHelpers BackpressureStrategy Define aTube
back-pressure management strategy.Concatenate<T> AFlow.Publisher
that is the concatenation of several ones.PublisherHelpers Recover<T> AFlow.Publisher
that recovers from failure using aFunction
.Retry<T> AFlow.Publisher
that retries on failure by re-subscribing to its upstream.Select<T> AFlow.Publisher
that selects elements matching aPredicate
.Transform<I,O> AFlow.Publisher
that transforms elements using aFunction
.Tube<T> ATube
is a general-purpose abstraction for creatingFlow.Publisher
.TubeConfiguration Configuration object for creatingTube
throughZeroPublisher.create(TubeConfiguration, Consumer)
.VertxPublisher Expose Vert.x streams as Reactive Streams compliant publishers.ZeroPublisher Factory methods to simplify the creation of reactive streams compliantFlow.Publisher
.