FlushStrategyHolder

java.lang.Object

io.servicetalk.transport.netty.internal.FlushStrategyHolder

public final class FlushStrategyHolder extends Object

A utility class to hold a FlushStrategy and allow it to be updated atomically using updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider).

Constructor Summary

Constructors

Constructor

Description

FlushStrategyHolder(FlushStrategy flushStrategy)

Creates new instance.
Method Summary

Modifier and Type

Method

Description

FlushStrategy

currentStrategy()

Returns the current value of the enclosed FlushStrategy.

Cancellable

updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider strategyProvider)

Updates FlushStrategy enclosed in this FlushStrategyHolder.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- FlushStrategyHolder
  
  public FlushStrategyHolder(FlushStrategy flushStrategy)
  
  Creates new instance.
  
  Parameters:
  
  flushStrategy - Initial FlushStrategy to use.
Method Details
- currentStrategy
  
  public FlushStrategy currentStrategy()
  
  Returns the current value of the enclosed FlushStrategy.
  
  Returns:
  
  Current value of the enclosed FlushStrategy.
- updateFlushStrategy
  
  public Cancellable updateFlushStrategy(NettyConnectionContext.FlushStrategyProvider strategyProvider)
  
  Updates FlushStrategy enclosed in this FlushStrategyHolder.
  
  Parameters:
  
  strategyProvider - NettyConnectionContext.FlushStrategyProvider to provide a new FlushStrategy. NettyConnectionContext.FlushStrategyProvider.computeFlushStrategy(FlushStrategy, boolean) MAY be invoked multiple times for a single call to this method and is expected to be idempotent.
  
  Returns:
  
  A Cancellable that will cancel this update.