Class BufferedEmittingPublisher.Builder<T>

java.lang.Object

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

Type Parameters:

T - type of the expected payload

All Implemented Interfaces:

Builder<BufferedEmittingPublisher.Builder<T>, BufferedEmittingPublisher<T>>, Supplier<BufferedEmittingPublisher<T>>

Enclosing class:

BufferedEmittingPublisher<T>

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

Fluent API builder to create BufferedEmittingPublisher.

Method Summary

Modifier and Type	Method	Description
BufferedEmittingPublisher.Builder<T>	buffer(Queue<T> queue)	Set up custom buffer queue implementation for the emitter to use.
BufferedEmittingPublisher<T>	build()	Build the instance from this builder.

Methods inherited from class Object

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

Methods inherited from interface Builder

get, identity, update

Modifier and Type	Method	Description
default BufferedEmittingPublisher<T>	get()
default BufferedEmittingPublisher.Builder<T>	identity()	Instance of this builder as the correct type.
default BufferedEmittingPublisher.Builder<T>	update(Consumer<BufferedEmittingPublisher.Builder<T>> consumer)	Update the builder in a fluent API way.

Method Details

buffer

public BufferedEmittingPublisher.Builder<T> buffer(Queue<T> queue)

Set up custom buffer queue implementation for the emitter to use.

Parameters:

queue - to be used as a buffer

Returns:

this builder

build

public BufferedEmittingPublisher<T> build()

Description copied from interface: Builder

Build the instance from this builder.

Specified by:

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

Returns:

instance of the built type