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 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 Multi<ByteBuffer>	get()
default IoMulti.MultiFromInputStreamBuilder	identity()	Instance of this builder as the correct type.
default IoMulti.MultiFromInputStreamBuilder	update(Consumer<IoMulti.MultiFromInputStreamBuilder> consumer)	Update the builder in a fluent API way.

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