io.servicetalk.transport.netty.internal

Class FlushStrategies

java.lang.Object

io.servicetalk.transport.netty.internal.FlushStrategies

public final class FlushStrategies
extends java.lang.Object

A factory for creating FlushStrategy.

Method Summary

Modifier and Type	Method and Description
static FlushStrategy	batchFlush(int batchSize, Publisher<?> durationBoundaries) Creates a FlushStrategy that will flush writes in a batch of batchSize or on expiration of a batch duration i.e.
static FlushStrategy	defaultFlushStrategy() Creates a default FlushStrategy.
static FlushStrategy	flushOnEach() Creates a FlushStrategy that will flush writes on each call to the returned FlushStrategy.WriteEventsListener.itemWritten(Object) from FlushStrategy.apply(FlushSender).
static FlushStrategy	flushOnEnd() Creates a FlushStrategy that will flush writes when FlushStrategy.WriteEventsListener.writeTerminated() is called on the FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender).
static FlushStrategy	flushWith(Publisher<?> flushBoundaries) Creates a FlushStrategy that will flush writes when an item is emitted from flushBoundaries.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

defaultFlushStrategy

public static FlushStrategy defaultFlushStrategy()

Creates a default FlushStrategy.

Returns:

Default FlushStrategy.

flushOnEach

public static FlushStrategy flushOnEach()

Creates a FlushStrategy that will flush writes on each call to the returned FlushStrategy.WriteEventsListener.itemWritten(Object) from FlushStrategy.apply(FlushSender).

Returns:

A FlushStrategy that will flush writes on each call to the returned FlushStrategy.WriteEventsListener.itemWritten(Object) from FlushStrategy.apply(FlushSender).

batchFlush

public static FlushStrategy batchFlush(int batchSize,
                                       Publisher<?> durationBoundaries)

Creates a FlushStrategy that will flush writes in a batch of batchSize or on expiration of a batch duration i.e. when an item is emitted from durationBoundaries.

Parameters:

batchSize - Number of items in each batch which needs flushing.

durationBoundaries - Batch durations. Every time an item is emitted on this Publisher, the returned FlushStrategy will flush writes.

Returns:

A FlushStrategy that will flush writes in a batch of batchSize or on expiration of a batch duration i.e. when an item is emitted from durationBoundaries.

flushWith

public static FlushStrategy flushWith(Publisher<?> flushBoundaries)

Creates a FlushStrategy that will flush writes when an item is emitted from flushBoundaries.

Parameters:

flushBoundaries - Flush boundaries. Every time an item is emitted on this Publisher, the returned FlushStrategy will flush writes.

Returns:

A FlushStrategy that will flush writes when an item is emitted from flushBoundaries.

flushOnEnd

public static FlushStrategy flushOnEnd()

Creates a FlushStrategy that will flush writes when FlushStrategy.WriteEventsListener.writeTerminated() is called on the FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender).

Returns:

A FlushStrategy that will flush writes when either of FlushStrategy.WriteEventsListener.writeTerminated() is called on the FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender).