Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class IoMulti.OutputStreamMultiBuilder

java.lang.Object

io.helidon.common.reactive.IoMulti.OutputStreamMultiBuilder

All Implemented Interfaces:

Builder<IoMulti.OutputStreamMultiBuilder,OutputStreamMulti>, Supplier<OutputStreamMulti>

Enclosing interface:

IoMulti

public static final class IoMulti.OutputStreamMultiBuilder
extends Object
implements Builder<IoMulti.OutputStreamMultiBuilder,OutputStreamMulti>

Fluent API builder for OutputStreamMulti.

Method Summary

Modifier and Type	Method	Description
OutputStreamMulti	build()	Build the instance from this builder.
IoMulti.OutputStreamMultiBuilder	onRequest(BiConsumer<Long,Long> requestCallback)	Callback executed when request signal from downstream arrive.
IoMulti.OutputStreamMultiBuilder	timeout(long timeout, TimeUnit unit)	Set max timeout for which is allowed to block write methods, in case there is no demand from downstream.

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

timeout

public IoMulti.OutputStreamMultiBuilder timeout(long timeout,
 TimeUnit unit)

Set max timeout for which is allowed to block write methods, in case there is no demand from downstream.

Parameters:

timeout - the maximum time to block

unit - the time unit of the timeout argument

Returns:

this builder

onRequest

public IoMulti.OutputStreamMultiBuilder onRequest(BiConsumer<Long,Long> requestCallback)

Callback executed when request signal from downstream arrive.

• param n the requested count.
• param demand the current total cumulative requested count, ranges between [0, Long.MAX_VALUE] where the max indicates that this publisher is unbounded.

Parameters:

requestCallback - to be executed

Returns:

this builder

build

public OutputStreamMulti build()

Description copied from interface: Builder

Build the instance from this builder.

Specified by:

build in interface Builder<IoMulti.OutputStreamMultiBuilder,OutputStreamMulti>

Returns:

instance of the built type