Uses of Interface
io.helidon.common.reactive.valve.Valve

Packages that use Valve

Package	Description
io.helidon.common.reactive.valve	Reactive utilities for Helidon projects.

Uses of Valve in io.helidon.common.reactive.valve

Classes in io.helidon.common.reactive.valve that implement Valve

Modifier and Type	Class	Description
class	InputStreamValve	The InputStreamValve is a ByteBuffer based Valve that transforms a possibly blocking InputStream into the Valve.
class	Tank<T>	Tank of events is a closeable FIFO queue with a limited size implementing Valve reactive API.

Methods in io.helidon.common.reactive.valve that return Valve

Modifier and Type	Method	Description
static <T> Valve<T>	Valves.empty()	Returns an empty Valve - instance, which report complete as soon as handler is registered.
default Valve<T>	Valve.executeOn(ExecutorService executorService)	Returns new Valve which defer all handlers to provided ExecutorService.
default Valve<T>	Valve.filter(Predicate<T> predicate)	Returns a Valve consisting of the elements of this Valve that match the given predicate.
default <K> Valve<K>	Valve.flatMap(Function<T,Valve<K>> mapFunction)	Returns new Valve instance which combines all results into a single Valve.
static <T> Valve<T>	Valves.from(Flow.Publisher<T> publisher)	Creates a Valve instance from provided Flow.Publisher.
static Valve<ByteBuffer>	Valves.from(InputStream stream, int bufferCapacity)	Creates a ByteBuffer based Valve instance from the provided InputStream.
static Valve<ByteBuffer>	Valves.from(InputStream stream, int bufferCapacity, ExecutorService executorService)	Creates a ByteBuffer based Valve instance from the provided InputStream.
static <T> Valve<T>	Valves.from(Iterable<T> iterable)	Creates a Valve instance from the provided Iterable.
static <T> Valve<T>	Valves.from(T... t)	Creates a Valve instance from provided array.
default <K> Valve<K>	Valve.map(Function<T,K> mapper)	Returns a Valve consisting of the results of applying the given function to the elements of this Valve.
default Valve<T>	Valve.peek(Consumer<T> action)	Returns a Valve consisting of the elements of this Valve, additionally performing the provided action on each element as elements are consumed from the resulting Valve.

Method parameters in io.helidon.common.reactive.valve with type arguments of type Valve

Modifier and Type	Method	Description
default <K> Valve<K>	Valve.flatMap(Function<T,Valve<K>> mapFunction)	Returns new Valve instance which combines all results into a single Valve.