reactor.netty

Interface NettyPipeline.SendOptions

Enclosing interface:

NettyPipeline

public static interface NettyPipeline.SendOptions

A builder for sending strategy, similar prefixed methods being mutually exclusive (flushXxx, prefetchXxx, requestXxx).

Method Summary

Modifier and Type	Method and Description
NettyPipeline.SendOptions	flushOnBoundary() Make the underlying channel flush on a terminated Publisher (default).
default NettyPipeline.SendOptions	flushOnEach() Make the underlying channel flush item by item.
NettyPipeline.SendOptions	flushOnEach(boolean withEventLoop) Make the underlying channel flush item by item.

Method Detail

flushOnBoundary

NettyPipeline.SendOptions flushOnBoundary()

Make the underlying channel flush on a terminated Publisher (default).

Returns:

this builder

flushOnEach

default NettyPipeline.SendOptions flushOnEach()

Make the underlying channel flush item by item. Flush operation will be executed at some time in the future.

Returns:

this builder

flushOnEach

NettyPipeline.SendOptions flushOnEach(boolean withEventLoop)

Make the underlying channel flush item by item. Whether flush operation is executed immediately or not is specified by withEventLoop parameter.

Parameters:

withEventLoop - flag specifying whether flush operation will be executed immediately or at some time in the future

Returns:

this builder