Class FlushStrategies
java.lang.Object
io.servicetalk.transport.netty.internal.FlushStrategies
A factory for creating
FlushStrategy
.-
Method Summary
Modifier and TypeMethodDescriptionstatic 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
Creates a defaultFlushStrategy
.static FlushStrategy
Creates aFlushStrategy
that willflush writes
on each call to the returnedFlushStrategy.WriteEventsListener.itemWritten(Object)
fromFlushStrategy.apply(FlushSender)
.static FlushStrategy
Creates aFlushStrategy
that willflush writes
whenFlushStrategy.WriteEventsListener.writeTerminated()
is called on theFlushStrategy.WriteEventsListener
returned fromFlushStrategy.apply(FlushSender)
.static FlushStrategy
-
Method Details
-
defaultFlushStrategy
Creates a defaultFlushStrategy
.- Returns:
- Default
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
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
- 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
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)
.
-