Module io.helidon.common.reactive

Package io.helidon.common.reactive

Class IoMulti.MultiToByteChannelBuilder

java.lang.Object

io.helidon.common.reactive.IoMulti.MultiToByteChannelBuilder

All Implemented Interfaces:

Builder<IoMulti.MultiToByteChannelBuilder,Function<? super Multi<ByteBuffer>,? extends Single<Void>>>, Supplier<Function<? super Multi<ByteBuffer>,? extends Single<Void>>>

Enclosing interface:

IoMulti

public static final class IoMulti.MultiToByteChannelBuilder
extends Object
implements Builder<IoMulti.MultiToByteChannelBuilder,Function<? super Multi<ByteBuffer>,? extends Single<Void>>>

Fluent API builder for creating a subscriber consuming Multi<ByteBuffer> to WritableByteChannel.

Method Summary

Modifier and Type	Method	Description
Function<? super Multi<ByteBuffer>,? extends Single<Void>>	build()	Build the instance from this builder.
IoMulti.MultiToByteChannelBuilder	executor(Executor executor)	Supply custom executor for handling the blocking of WritableByteChannel.

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

executor

public IoMulti.MultiToByteChannelBuilder executor(Executor executor)

Supply custom executor for handling the blocking of WritableByteChannel.

Parameters:

executor - custom executor

Returns:

updated builder instance

build

public Function<? super Multi<ByteBuffer>,? extends Single<Void>> build()

Description copied from interface: Builder

Build the instance from this builder.

Specified by:

build in interface Builder<IoMulti.MultiToByteChannelBuilder,Function<? super Multi<ByteBuffer>,? extends Single<Void>>>

Returns:

instance of the built type