Uses of Interface
io.helidon.common.reactive.valve.Pausable
-
Packages that use Pausable Package Description io.helidon.common.reactive.valve Reactive utilities for Helidon projects. -
-
Uses of Pausable in io.helidon.common.reactive.valve
Subinterfaces of Pausable in io.helidon.common.reactive.valve Modifier and Type Interface Description interface
Valve<T>
Classes in io.helidon.common.reactive.valve that implement Pausable Modifier and Type Class Description class
InputStreamValve
The InputStreamValve is aByteBuffer
basedValve
that transforms a possibly blockingInputStream
into the Valve.class
Tank<T>
Tank of events is a closeable FIFO queue with a limited size implementingValve
reactive API.Method parameters in io.helidon.common.reactive.valve with type arguments of type Pausable Modifier and Type Method Description void
Tank. handle(BiConsumer<T,Pausable> onData, Consumer<Throwable> onError, Runnable onComplete)
default void
Valve. handle(BiConsumer<T,Pausable> onData)
Register data handlers (callbacks).default void
Valve. handle(BiConsumer<T,Pausable> onData, Consumer<Throwable> onError)
Register data handlers (callbacks).void
Valve. handle(BiConsumer<T,Pausable> onData, Consumer<Throwable> onError, Runnable onComplete)
Register data handlers (callbacks).
-