io.servicetalk.transport.netty.internal

Class MockFlushStrategy

java.lang.Object

io.servicetalk.transport.netty.internal.MockFlushStrategy

All Implemented Interfaces:

FlushStrategy

public final class MockFlushStrategy
extends java.lang.Object
implements FlushStrategy

A mocking setup for FlushStrategy that provides ways to verify interactions with WriteEventsListener and also provides access to FlushSender.

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
MockFlushStrategy() New instance.

Method Summary

Modifier and Type	Method and Description
void	afterFirstWrite(java.util.function.Consumer<FlushStrategy.FlushSender> senderConsumer) Invoke some code on the first invocation of WriteEventsListener#itemWritten(Object).
FlushStrategy.WriteEventsListener	apply(FlushStrategy.FlushSender sender) Every time a new write that requires custom flushes is initiated, this method is invoked.
FlushStrategy.FlushSender	verifyApplied() Verifies that this FlushStrategy was applied.
void	verifyItemWritten(int count) Verifies whether WriteEventsListener#itemWritten(Object) was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).
void	verifyNoMoreInteractions() Verifies there were no more interactions with the WriteEventsListener returned from FlushStrategy.apply(FlushSender).
void	verifyWriteCancelled() Verifies whether WriteEventsListener#writeCancelled() was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).
void	verifyWriteStarted() Verifies whether WriteEventsListener#writeStarted() was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).
void	verifyWriteTerminated() Verifies whether WriteEventsListener#writeTerminated() was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.servicetalk.transport.netty.internal.FlushStrategy

shouldFlushOnUnwritable

Constructor Detail

MockFlushStrategy

public MockFlushStrategy()

New instance.

Method Detail

verifyApplied

public FlushStrategy.FlushSender verifyApplied()

Verifies that this FlushStrategy was applied.

Returns:

FlushSender provided to FlushStrategy.apply(FlushSender).

verifyWriteStarted

public void verifyWriteStarted()

Verifies whether WriteEventsListener#writeStarted() was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).

verifyItemWritten

public void verifyItemWritten(int count)

Verifies whether WriteEventsListener#itemWritten(Object) was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).

Parameters:

count - Number of times WriteEventsListener#itemWritten(Object) is expected to be called.

verifyWriteTerminated

public void verifyWriteTerminated()

Verifies whether WriteEventsListener#writeTerminated() was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).

verifyWriteCancelled

public void verifyWriteCancelled()

Verifies whether WriteEventsListener#writeCancelled() was called for the WriteEventsListener returned from FlushStrategy.apply(FlushSender).

verifyNoMoreInteractions

public void verifyNoMoreInteractions()

Verifies there were no more interactions with the WriteEventsListener returned from FlushStrategy.apply(FlushSender).

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.

afterFirstWrite

public void afterFirstWrite(java.util.function.Consumer<FlushStrategy.FlushSender> senderConsumer)

Invoke some code on the first invocation of WriteEventsListener#itemWritten(Object).

Parameters:

senderConsumer - A Consumer that is given the FlushSender after WriteEventsListener#itemWritten(Object).