io.servicetalk.transport.netty.internal

Class DelegatingFlushStrategy

java.lang.Object

io.servicetalk.transport.netty.internal.DelegatingFlushStrategy

All Implemented Interfaces:

FlushStrategy

public class DelegatingFlushStrategy
extends java.lang.Object
implements FlushStrategy

A FlushStrategy implementation that delegates all calls to another FlushStrategy.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.transport.netty.internal.FlushStrategy

FlushStrategy.FlushSender, FlushStrategy.WriteEventsListener

Constructor Summary

Constructors

Constructor and Description
DelegatingFlushStrategy(FlushStrategy delegate) Create a new instance.

Method Summary

Modifier and Type	Method and Description
FlushStrategy.WriteEventsListener	apply(FlushStrategy.FlushSender sender) Every time a new write that requires custom flushes is initiated, this method is invoked.
protected FlushStrategy	delegate() Returns the delegate FlushStrategy used.
boolean	shouldFlushOnUnwritable() Returns true if pending writes, if any, MUST be flushed when the connection is not writable.

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingFlushStrategy

public DelegatingFlushStrategy(FlushStrategy delegate)

Create a new instance.

Parameters:

delegate - FlushStrategy to delegate all calls.

Method Detail

apply

public FlushStrategy.WriteEventsListener apply(FlushStrategy.FlushSender sender)

Description copied from interface: FlushStrategy

Every time a new write that requires custom flushes is initiated, this method is invoked. Passed FlushStrategy.FlushSender is used to signal to the connection that writes should now be flushed.

Specified by:

apply in interface FlushStrategy

Parameters:

sender - FlushStrategy.FlushSender to signal flushes to the connection.

Returns:

FlushStrategy.WriteEventsListener that would listen to write events on the connection for which custom flushes are required.

shouldFlushOnUnwritable

public boolean shouldFlushOnUnwritable()

Description copied from interface: FlushStrategy

Returns true if pending writes, if any, MUST be flushed when the connection is not writable.

This method is expected to be idempotent.

Specified by:

shouldFlushOnUnwritable in interface FlushStrategy

Returns:

true if pending writes, if any, MUST be flushed when the connection is not writable.

delegate

protected FlushStrategy delegate()

Returns the delegate FlushStrategy used.

Returns:

The delegate FlushStrategy used.