Uses of Interface
mutiny.zero.Tube

Packages that use Tube

Package	Description
mutiny.zero	Mutiny Zero is minimal API for creating reactive streams compliant Publisher objects.

Uses of Tube in mutiny.zero

Methods in mutiny.zero that return Tube

Modifier and Type	Method	Description
Tube<T>	Tube.send(T item)	Send an item.
Tube<T>	Tube.whenCancelled(java.lang.Runnable action)	Define an action when the subscription is cancelled.
Tube<T>	Tube.whenRequested(java.util.function.LongConsumer consumer)	Define an action when items are being requested.
Tube<T>	Tube.whenTerminates(java.lang.Runnable action)	Define an action on termination (completion, error or cancellation), typically for cleanup purposes.

Method parameters in mutiny.zero with type arguments of type Tube

Modifier and Type	Method	Description
static <T> org.reactivestreams.Publisher<T>	ZeroPublisher.create(BackpressureStrategy backpressureStrategy, int bufferSize, java.util.function.Consumer<Tube<T>> tubeConsumer)	Deprecated. Use ZeroPublisher.create(TubeConfiguration, Consumer) instead
static <T> org.reactivestreams.Publisher<T>	ZeroPublisher.create(TubeConfiguration configuration, java.util.function.Consumer<Tube<T>> tubeConsumer)	Create a new Publisher with the general-purpose Tube API.