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>	Represents a reactive source of data which can be paused and resumed.

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

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.

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).