Package 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 Object
implements ConnectionObserver.ReadObserver

Noop version of ConnectionObserver.ReadObserver.

Field Summary

Fields

Modifier and Type	Field	Description
static final ConnectionObserver.ReadObserver	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	itemRead(Object item)	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(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

Methods inherited from interface io.servicetalk.transport.api.ConnectionObserver.ReadObserver

itemRead

Field Details

INSTANCE

public static final ConnectionObserver.ReadObserver INSTANCE

Method Details

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(@Nullable
 Object item)

Description copied from interface: ConnectionObserver.ReadObserver

Invokes when a new item is read.

Specified by:

itemRead in interface ConnectionObserver.ReadObserver

Parameters:

item - an item that was read

readFailed

public void readFailed(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