Module io.helidon.common.reactive

Package io.helidon.common.reactive

Interface IoMulti

public interface IoMulti

Create reactive stream from standard IO resources.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	IoMulti.MultiFromInputStreamBuilder
static class	IoMulti.OutputStreamMultiBuilder

Method Summary

Static Methods

Modifier and Type	Method	Description
static IoMulti.MultiFromInputStreamBuilder	builderInputStream(InputStream inputStream)	Creates a builder of the Multi from supplied InputStream.
static IoMulti.OutputStreamMultiBuilder	builderOutputStream()	Creates a builder of the Multi publisher, to which is possible to publish as in to an OutputStream.
static Multi<ByteBuffer>	createInputStream(InputStream inputStream)	Create a Multi instance that publishes ByteBuffers from the given InputStream.
static MultiFromOutputStream	createOutputStream()	Create a Multi publisher, to which is possible to publish as in to an OutputStream.

Method Detail

createOutputStream

static MultiFromOutputStream createOutputStream()

Create a Multi publisher, to which is possible to publish as in to an OutputStream. In case there is no demand, OutputStream.write(byte[], int, int) methods are blocked until downstream request for more data.

Returns:

new Multi publisher extending OutputStream

builderOutputStream

static IoMulti.OutputStreamMultiBuilder builderOutputStream()

Creates a builder of the Multi publisher, to which is possible to publish as in to an OutputStream. In case there is no demand, OutputStream.write(byte[], int, int) methods are blocked until downstream request for more data.

Returns:

the builder

createInputStream

static Multi<ByteBuffer> createInputStream(InputStream inputStream)

Create a Multi instance that publishes ByteBuffers from the given InputStream.

InputStream is trusted not to block on read operations, in case it can't be assured use builder to specify executor for asynchronous waiting for blocking reads. IoMulti.builder(is).executor(executorService).build().

Parameters:

inputStream - the Stream to publish

Returns:

Multi

Throws:

NullPointerException - if stream is null

builderInputStream

static IoMulti.MultiFromInputStreamBuilder builderInputStream(InputStream inputStream)

Creates a builder of the Multi from supplied InputStream.

Parameters:

inputStream - the Stream to publish

Returns:

the builder