Package 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 FlushStrategy.WriteEventsListener and also provides access to FlushStrategy.FlushSender.

Nested Class Summary

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

FlushStrategy.FlushSender, FlushStrategy.WriteEventsListener

Constructor Summary

Constructors

Constructor	Description
MockFlushStrategy()	New instance.

Method Summary

Modifier and Type	Method	Description
void	afterFirstWrite(java.util.function.Consumer<FlushStrategy.FlushSender> senderConsumer)	Invoke some code on the first invocation of FlushStrategy.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 FlushStrategy.WriteEventsListener.itemWritten(Object) was called for the FlushStrategy.WriteEventsListener returned from apply(FlushSender).
void	verifyNoMoreInteractions()	Verifies there were no more interactions with the FlushStrategy.WriteEventsListener returned from apply(FlushSender).
void	verifyWriteCancelled()	Verifies whether FlushStrategy.WriteEventsListener.writeCancelled() was called for the FlushStrategy.WriteEventsListener returned from apply(FlushSender).
void	verifyWriteStarted()	Verifies whether FlushStrategy.WriteEventsListener.writeStarted() was called for the FlushStrategy.WriteEventsListener returned from apply(FlushSender).
void	verifyWriteTerminated()	Verifies whether FlushStrategy.WriteEventsListener.writeTerminated() was called for the FlushStrategy.WriteEventsListener returned from 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:

FlushStrategy.FlushSender provided to apply(FlushSender).

verifyWriteStarted

public void verifyWriteStarted()

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

verifyItemWritten

public void verifyItemWritten(int count)

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

Parameters:

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

verifyWriteTerminated

public void verifyWriteTerminated()

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

verifyWriteCancelled

public void verifyWriteCancelled()

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

verifyNoMoreInteractions

public void verifyNoMoreInteractions()

Verifies there were no more interactions with the FlushStrategy.WriteEventsListener returned from 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 FlushStrategy.WriteEventsListener.itemWritten(Object).

Parameters:

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