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<Multi<ByteBuffer>>,Supplier<Multi<ByteBuffer>>
- Enclosing interface:
- IoMulti
public static final class IoMulti.MultiFromInputStreamBuilder extends Object implements Builder<Multi<ByteBuffer>>
Fluent API builder for creating aMultifrom anInputStream.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Multi<ByteBuffer>build()Build the instance from this builder.IoMulti.MultiFromInputStreamBuilderbyteBufferSize(int bufferSize)Set the size ofByteBuffers being published.IoMulti.MultiFromInputStreamBuilderexecutor(ExecutorService executor)If theInputStreamcan block in read method, use executor for asynchronous waiting.
-
-
-
Method Detail
-
byteBufferSize
public IoMulti.MultiFromInputStreamBuilder byteBufferSize(int bufferSize)
Set the size ofByteBuffers being published.- Parameters:
bufferSize- size of theByteBuffer- Returns:
- Multi
-
executor
public IoMulti.MultiFromInputStreamBuilder executor(ExecutorService executor)
If theInputStreamcan 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:BuilderBuild the instance from this builder.- Specified by:
buildin interfaceBuilder<Multi<ByteBuffer>>- Returns:
- instance of the built type
-
-