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 aMulti
from anInputStream
.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Multi<ByteBuffer>
build()
Build the instance from this builder.IoMulti.MultiFromInputStreamBuilder
byteBufferSize(int bufferSize)
Set the size ofByteBuffer
s being published.IoMulti.MultiFromInputStreamBuilder
executor(ExecutorService executor)
If theInputStream
can block in read method, use executor for asynchronous waiting.
-
-
-
Method Detail
-
byteBufferSize
public IoMulti.MultiFromInputStreamBuilder byteBufferSize(int bufferSize)
Set the size ofByteBuffer
s being published.- Parameters:
bufferSize
- size of theByteBuffer
- Returns:
- Multi
-
executor
public IoMulti.MultiFromInputStreamBuilder executor(ExecutorService executor)
If theInputStream
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 interfaceBuilder<Multi<ByteBuffer>>
- Returns:
- instance of the built type
-
-