Module io.smallrye.mutiny.zero

Package mutiny.zero.operators

package mutiny.zero.operators

This package contains a set of simple operator classes that can be useful when working with Flow.Publisher streams.

Each operator class is a Flow.Publisher that accepts an upstream Flow.Publisher and parameters.

These operators are not designed to rival the performance of those found in a more reactive programming library like Smallrye Mutiny. They cover common patterns that might be useful when exposing Flow.Publisher types.

Related Packages

Module	Package	Description
io.smallrye.mutiny.zero	mutiny.zero	Mutiny Zero is minimal API for creating reactive streams compliant Flow.Publisher objects.
io.smallrye.mutiny.zero.vertxpublishers	mutiny.zero.vertxpublishers

Classes

Class	Description
Concatenate<T>	A Flow.Publisher that is the concatenation of several ones.
Recover<T>	A Flow.Publisher that recovers from failure using a Function.
Retry<T>	A Flow.Publisher that retries on failure by re-subscribing to its upstream.
Select<T>	A Flow.Publisher that selects elements matching a Predicate.
Spread<T,R>	A Flow.Publisher that maps each upstream item to a Flow.Publisher and flattens the results with bounded concurrency.
Transform<I,O>	A Flow.Publisher that transforms elements using a Function.