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 ofConnectionObserver.ReadObserver
.
-
-
Field Summary
Fields Modifier and Type Field Description static ConnectionObserver.ReadObserver
INSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 anerror
.void
requestedToRead(long n)
Callback when new items are requested to read.
-
-
-
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 interfaceConnectionObserver.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 interfaceConnectionObserver.ReadObserver
-
readFailed
public void readFailed(java.lang.Throwable cause)
Description copied from interface:ConnectionObserver.ReadObserver
Callback when the read operation fails with anerror
.- Specified by:
readFailed
in interfaceConnectionObserver.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 interfaceConnectionObserver.ReadObserver
-
readCancelled
public void readCancelled()
Description copied from interface:ConnectionObserver.ReadObserver
Callback when the read operation is cancelled.- Specified by:
readCancelled
in interfaceConnectionObserver.ReadObserver
-
-