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 java.lang.Object
implements ConnectionObserver.WriteObserver

Noop version of ConnectionObserver.WriteObserver.

Field Summary

Fields

Modifier and Type	Field	Description
static ConnectionObserver.WriteObserver	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	itemReceived()	Callback when an item is received and ready to be written.
void	itemWritten()	Callback when an item is written to the transport.
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(java.lang.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

Field Detail

INSTANCE

public static final ConnectionObserver.WriteObserver INSTANCE

Method Detail

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()

Description copied from interface: ConnectionObserver.WriteObserver

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

Content of the received items should be inspected at the higher level API when these items are produced.

Specified by:

itemReceived in interface ConnectionObserver.WriteObserver

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()

Description copied from interface: ConnectionObserver.WriteObserver

Callback when an item is written to the transport.

Content of the written items should be inspected at the higher level API when these items are produced.

Specified by:

itemWritten in interface ConnectionObserver.WriteObserver

writeFailed

public void writeFailed(java.lang.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