Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class IoMulti.MultiFromInputStreamBuilder

java.lang.Object

io.helidon.common.reactive.IoMulti.MultiFromInputStreamBuilder

All Implemented Interfaces:

Builder<IoMulti.MultiFromInputStreamBuilder,Multi<ByteBuffer>>, Supplier<Multi<ByteBuffer>>

Enclosing interface:

IoMulti

public static final class IoMulti.MultiFromInputStreamBuilder
extends Object
implements Builder<IoMulti.MultiFromInputStreamBuilder,Multi<ByteBuffer>>

Fluent API builder for creating a Multi from an InputStream.

Method Summary

Modifier and Type	Method	Description
Multi<ByteBuffer>	build()	Build the instance from this builder.
IoMulti.MultiFromInputStreamBuilder	byteBufferSize(int bufferSize)	Set the size of ByteBuffers being published.
IoMulti.MultiFromInputStreamBuilder	executor(ExecutorService executor)	If the InputStream can block in read method, use executor for asynchronous waiting.

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

byteBufferSize

public IoMulti.MultiFromInputStreamBuilder byteBufferSize(int bufferSize)

Set the size of ByteBuffers being published.

Parameters:

bufferSize - size of the ByteBuffer

Returns:

Multi

executor

public IoMulti.MultiFromInputStreamBuilder executor(ExecutorService executor)

If the InputStream can block in read method, use executor for asynchronous waiting.

Parameters:

executor - used for asynchronous waiting for blocking reads

Returns:

this builder

build

public Multi<ByteBuffer> build()

Description copied from interface: Builder

Build the instance from this builder.

Specified by:

build in interface Builder<IoMulti.MultiFromInputStreamBuilder,Multi<ByteBuffer>>

Returns:

instance of the built type