io.servicetalk.transport.netty.internal

Class NoopTransportObserver.NoopReadObserver

java.lang.Object

io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopReadObserver

All Implemented Interfaces:

ConnectionObserver.ReadObserver

Enclosing class:

NoopTransportObserver

public static final class NoopTransportObserver.NoopReadObserver
extends java.lang.Object
implements ConnectionObserver.ReadObserver

Noop version of ConnectionObserver.ReadObserver.

Field Summary

Fields

Modifier and Type	Field and Description
static ConnectionObserver.ReadObserver	INSTANCE

Method Summary

Modifier and Type	Method and Description
void	itemRead() Invokes when a new item is read.
void	readCancelled() Callback when the read operation is cancelled.
void	readComplete() Callback when the entire read operation completes successfully.
void	readFailed(java.lang.Throwable cause) Callback when the read operation fails with an error.
void	requestedToRead(long n) Callback when new items are requested to read.

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.ReadObserver INSTANCE

Method Detail

requestedToRead

public void requestedToRead(long n)

Description copied from interface: ConnectionObserver.ReadObserver

Callback when new items are requested to read.

Specified by:

requestedToRead in interface ConnectionObserver.ReadObserver

Parameters:

n - number of requested items to read

itemRead

public void itemRead()

Description copied from interface: ConnectionObserver.ReadObserver

Invokes when a new item is read.

Content of the read items should be inspected at the higher level API when these items are consumed.

Specified by:

itemRead in interface ConnectionObserver.ReadObserver

readFailed

public void readFailed(java.lang.Throwable cause)

Description copied from interface: ConnectionObserver.ReadObserver

Callback when the read operation fails with an error.

Specified by:

readFailed in interface ConnectionObserver.ReadObserver

Parameters:

cause - Throwable that terminated the read

readComplete

public void readComplete()

Description copied from interface: ConnectionObserver.ReadObserver

Callback when the entire read operation completes successfully.

Specified by:

readComplete in interface ConnectionObserver.ReadObserver

readCancelled

public void readCancelled()

Description copied from interface: ConnectionObserver.ReadObserver

Callback when the read operation is cancelled.

Specified by:

readCancelled in interface ConnectionObserver.ReadObserver