io.servicetalk.transport.netty.internal

Class FlushStrategyHolder

java.lang.Object

io.servicetalk.transport.netty.internal.FlushStrategyHolder

public final class FlushStrategyHolder
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
FlushStrategyHolder(FlushStrategy flushStrategy) Creates new instance.

Method Summary

Modifier and Type	Method and 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 Detail

FlushStrategyHolder

public FlushStrategyHolder(FlushStrategy flushStrategy)

Creates new instance.

Parameters:

flushStrategy - Initial FlushStrategy to use.

Method Detail

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.