Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class MultiTappedPublisher.Builder<T>

java.lang.Object

io.helidon.common.reactive.MultiTappedPublisher.Builder<T>

Type Parameters:

T - type of returned multi

All Implemented Interfaces:

Builder<MultiTappedPublisher.Builder<T>,MultiTappedPublisher<T>>, Supplier<MultiTappedPublisher<T>>

Enclosing class:

MultiTappedPublisher<T>

public static class MultiTappedPublisher.Builder<T>
extends Object
implements Builder<MultiTappedPublisher.Builder<T>,MultiTappedPublisher<T>>

Multi tapped publisher builder to register custom callbacks.

Method Summary

Modifier and Type	Method	Description
MultiTappedPublisher<T>	build()	Build the instance from this builder.
MultiTappedPublisher.Builder<T>	onCancelCallback(Runnable onCancelCallback)	On cancel callback.
MultiTappedPublisher.Builder<T>	onCompleteCallback(Runnable onCompleteCallback)	On complete callback.
MultiTappedPublisher.Builder<T>	onErrorCallback(Consumer<? super Throwable> onErrorCallback)	On error callback.
MultiTappedPublisher.Builder<T>	onNextCallback(Consumer<? super T> onNextCallback)	On next callback.
MultiTappedPublisher.Builder<T>	onRequestCallback(LongConsumer onRequestCallback)	On request callback.
MultiTappedPublisher.Builder<T>	onSubscribeCallback(Runnable onSubscribeCallback)	Subscription callback.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.common.Builder

get, identity, update

Method Details

build

public MultiTappedPublisher<T> build()

Description copied from interface: Builder

Build the instance from this builder.

Specified by:

build in interface Builder<MultiTappedPublisher.Builder<T>,MultiTappedPublisher<T>>

Returns:

instance of the built type

onSubscribeCallback

public MultiTappedPublisher.Builder<T> onSubscribeCallback(Runnable onSubscribeCallback)

Subscription callback.

Parameters:

onSubscribeCallback - runnable to run when Flow.Subscriber.onSubscribe(java.util.concurrent.Flow.Subscription) is called

Returns:

updated builder instance

onNextCallback

public MultiTappedPublisher.Builder<T> onNextCallback(Consumer<? super T> onNextCallback)

On next callback.

Parameters:

onNextCallback - runnable to run when Flow.Subscriber.onNext(Object) is called

Returns:

updated builder instance

onCompleteCallback

public MultiTappedPublisher.Builder<T> onCompleteCallback(Runnable onCompleteCallback)

On complete callback.

Parameters:

onCompleteCallback - runnable to run when Flow.Subscriber.onComplete() is called

Returns:

updated builder instance

onRequestCallback

public MultiTappedPublisher.Builder<T> onRequestCallback(LongConsumer onRequestCallback)

On request callback.

Parameters:

onRequestCallback - runnable to run when Flow.Subscription.request(long) is called

Returns:

updated builder instance

onCancelCallback

public MultiTappedPublisher.Builder<T> onCancelCallback(Runnable onCancelCallback)

On cancel callback.

Parameters:

onCancelCallback - runnable to run when Flow.Subscription.cancel() is called

Returns:

updated builder instance

onErrorCallback

public MultiTappedPublisher.Builder<T> onErrorCallback(Consumer<? super Throwable> onErrorCallback)

On error callback.

Parameters:

onErrorCallback - runnable to run when Flow.Subscriber.onError(Throwable) is called

Returns:

updated builder instance