Package io.servicetalk.transport.netty.internal

Class NoopWriteEventsListener

java.lang.Object

io.servicetalk.transport.netty.internal.NoopWriteEventsListener

All Implemented Interfaces:

FlushStrategy.WriteEventsListener

public abstract class NoopWriteEventsListener
extends Object
implements FlushStrategy.WriteEventsListener

A FlushStrategy.WriteEventsListener that by default does nothing for all method. This can be used to selectively implement relevant methods.

Constructor Summary

Constructors

Constructor	Description
NoopWriteEventsListener()

Method Summary

Modifier and Type	Method	Description
void	itemWritten(Object __)	For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called once after any item is written to the connection.
void	writeCancelled()	For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called at most once when writes are cancelled.
void	writeStarted()	For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called at most once before any items are written to the connection.
void	writeTerminated()	For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called at most once when all other items are written to the connection.

Methods inherited from class java.lang.Object

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

Constructor Details

NoopWriteEventsListener

public NoopWriteEventsListener()

Method Details

writeStarted

public void writeStarted()

Description copied from interface: FlushStrategy.WriteEventsListener

For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called at most once before any items are written to the connection.

This will be followed by zero or more calls to FlushStrategy.WriteEventsListener.itemWritten(Object) and at most one call to FlushStrategy.WriteEventsListener.writeTerminated() and FlushStrategy.WriteEventsListener.writeCancelled() or both.

Specified by:

writeStarted in interface FlushStrategy.WriteEventsListener

itemWritten

public void itemWritten(Object __)

Description copied from interface: FlushStrategy.WriteEventsListener

For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called once after any item is written to the connection.

This will be followed by zero or more calls to this method and at most one call to FlushStrategy.WriteEventsListener.writeTerminated() and FlushStrategy.WriteEventsListener.writeCancelled() or both. FlushStrategy.WriteEventsListener.writeCancelled() can be called concurrently with this method.

Specified by:

itemWritten in interface FlushStrategy.WriteEventsListener

Parameters:

__ - Item that was written.

writeTerminated

public void writeTerminated()

Description copied from interface: FlushStrategy.WriteEventsListener

For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called at most once when all other items are written to the connection.

FlushStrategy.WriteEventsListener.writeCancelled() MAY be called concurrently or after this method.

Specified by:

writeTerminated in interface FlushStrategy.WriteEventsListener

writeCancelled

public void writeCancelled()

Description copied from interface: FlushStrategy.WriteEventsListener

For each new FlushStrategy.WriteEventsListener returned from FlushStrategy.apply(FlushSender), this method will be called at most once when writes are cancelled.

FlushStrategy.WriteEventsListener.itemWritten(Object) or FlushStrategy.WriteEventsListener.writeTerminated() MAY be called concurrently or after this method.

Specified by:

writeCancelled in interface FlushStrategy.WriteEventsListener