Class FlushStrategies
- java.lang.Object
-
- io.servicetalk.transport.netty.internal.FlushStrategies
-
public final class FlushStrategies extends java.lang.Object
A factory for creatingFlushStrategy
.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static FlushStrategy
batchFlush(int batchSize, Publisher<?> durationBoundaries)
Creates aFlushStrategy
that willflush writes
in a batch ofbatchSize
or on expiration of a batch duration i.e.static FlushStrategy
defaultFlushStrategy()
Creates a defaultFlushStrategy
.static FlushStrategy
flushOnEach()
Creates aFlushStrategy
that willflush writes
on each call to the returnedFlushStrategy.WriteEventsListener.itemWritten(Object)
fromFlushStrategy.apply(FlushSender)
.static FlushStrategy
flushOnEnd()
Creates aFlushStrategy
that willflush writes
whenFlushStrategy.WriteEventsListener.writeTerminated()
is called on theFlushStrategy.WriteEventsListener
returned fromFlushStrategy.apply(FlushSender)
.static FlushStrategy
flushWith(Publisher<?> flushBoundaries)
-
-
-
Method Detail
-
defaultFlushStrategy
public static FlushStrategy defaultFlushStrategy()
Creates a defaultFlushStrategy
.- Returns:
- Default
FlushStrategy
.
-
flushOnEach
public static FlushStrategy flushOnEach()
Creates aFlushStrategy
that willflush writes
on each call to the returnedFlushStrategy.WriteEventsListener.itemWritten(Object)
fromFlushStrategy.apply(FlushSender)
.- Returns:
- A
FlushStrategy
that willflush writes
on each call to the returnedFlushStrategy.WriteEventsListener.itemWritten(Object)
fromFlushStrategy.apply(FlushSender)
.
-
batchFlush
public static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries)
Creates aFlushStrategy
that willflush writes
in a batch ofbatchSize
or on expiration of a batch duration i.e. when an item is emitted fromdurationBoundaries
.- Parameters:
batchSize
- Number of items in each batch which needs flushing.durationBoundaries
- Batch durations. Every time an item is emitted on thisPublisher
, the returnedFlushStrategy
willflush writes
.- Returns:
- A
FlushStrategy
that willflush writes
in a batch ofbatchSize
or on expiration of a batch duration i.e. when an item is emitted fromdurationBoundaries
.
-
flushWith
public static FlushStrategy flushWith(Publisher<?> flushBoundaries)
- Parameters:
flushBoundaries
- Flush boundaries. Every time an item is emitted on thisPublisher
, the returnedFlushStrategy
willflush writes
.- Returns:
- A
FlushStrategy
that willflush writes
when an item is emitted fromflushBoundaries
.
-
flushOnEnd
public static FlushStrategy flushOnEnd()
Creates aFlushStrategy
that willflush writes
whenFlushStrategy.WriteEventsListener.writeTerminated()
is called on theFlushStrategy.WriteEventsListener
returned fromFlushStrategy.apply(FlushSender)
.- Returns:
- A
FlushStrategy
that willflush writes
when either ofFlushStrategy.WriteEventsListener.writeTerminated()
is called on theFlushStrategy.WriteEventsListener
returned fromFlushStrategy.apply(FlushSender)
.
-
-