Package io.servicetalk.transport.netty.internal

Class NoopTransportObserver.NoopWriteObserver

java.lang.Object

io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopWriteObserver

All Implemented Interfaces:

ConnectionObserver.WriteObserver

Enclosing class:

NoopTransportObserver

public static final class NoopTransportObserver.NoopWriteObserver
extends Object
implements ConnectionObserver.WriteObserver

Noop version of ConnectionObserver.WriteObserver.

Field Summary

Fields

Modifier and Type	Field	Description
static final ConnectionObserver.WriteObserver	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	itemFlushed()	Callback when an item is flushed to the network.
void	itemReceived(Object item)	Callback when an item is received and ready to be written.
void	itemWritten(Object item)	Callback when an item is serialized and written to the socket.
void	onFlushRequest()	Callback when flush operation is requested.
void	requestedToWrite(long n)	Callback when new items are requested to write.
void	writeCancelled()	Callback when the write operation is cancelled.
void	writeComplete()	Callback when the entire write operation completes successfully.
void	writeFailed(Throwable cause)	Callback when the write operation fails with an error.

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.api.ConnectionObserver.WriteObserver

itemReceived, itemWritten

Field Details

INSTANCE

public static final ConnectionObserver.WriteObserver INSTANCE

Method Details

requestedToWrite

public void requestedToWrite(long n)

Description copied from interface: ConnectionObserver.WriteObserver

Callback when new items are requested to write.

Specified by:

requestedToWrite in interface ConnectionObserver.WriteObserver

Parameters:

n - number of requested items to write

itemReceived

public void itemReceived(@Nullable
 Object item)

Description copied from interface: ConnectionObserver.WriteObserver

Callback when an item is received and ready to be written.

Specified by:

itemReceived in interface ConnectionObserver.WriteObserver

Parameters:

item - received item

onFlushRequest

public void onFlushRequest()

Description copied from interface: ConnectionObserver.WriteObserver

Callback when flush operation is requested.

Specified by:

onFlushRequest in interface ConnectionObserver.WriteObserver

itemWritten

public void itemWritten(@Nullable
 Object item)

Description copied from interface: ConnectionObserver.WriteObserver

Callback when an item is serialized and written to the socket.

Specified by:

itemWritten in interface ConnectionObserver.WriteObserver

Parameters:

item - written item

itemFlushed

public void itemFlushed()

Description copied from interface: ConnectionObserver.WriteObserver

Callback when an item is flushed to the network. Items are flushed in order they have been written.

Specified by:

itemFlushed in interface ConnectionObserver.WriteObserver

writeFailed

public void writeFailed(Throwable cause)

Description copied from interface: ConnectionObserver.WriteObserver

Callback when the write operation fails with an error.

Specified by:

writeFailed in interface ConnectionObserver.WriteObserver

Parameters:

cause - Throwable that terminated the write

writeComplete

public void writeComplete()

Description copied from interface: ConnectionObserver.WriteObserver

Callback when the entire write operation completes successfully.

Specified by:

writeComplete in interface ConnectionObserver.WriteObserver

writeCancelled

public void writeCancelled()

Description copied from interface: ConnectionObserver.WriteObserver

Callback when the write operation is cancelled.

Specified by:

writeCancelled in interface ConnectionObserver.WriteObserver