DelegatingFlushStrategy

java.lang.Object

io.servicetalk.transport.netty.internal.DelegatingFlushStrategy

All Implemented Interfaces:: FlushStrategy

public class DelegatingFlushStrategy extends 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

Description

DelegatingFlushStrategy(FlushStrategy delegate)

Create a new instance.
Method Summary

Modifier and Type

Method

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 Details
- DelegatingFlushStrategy
  
  public DelegatingFlushStrategy(FlushStrategy delegate)
  
  Create a new instance.
  
  Parameters:
  
  delegate - FlushStrategy to delegate all calls.
Method Details
- 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.