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 ofConnectionObserver.WriteObserver
.
-
-
Field Summary
Fields Modifier and Type Field Description static ConnectionObserver.WriteObserver
INSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods 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 anerror
.
-
-
-
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 interfaceConnectionObserver.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 interfaceConnectionObserver.WriteObserver
-
onFlushRequest
public void onFlushRequest()
Description copied from interface:ConnectionObserver.WriteObserver
Callback when flush operation is requested.- Specified by:
onFlushRequest
in interfaceConnectionObserver.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 interfaceConnectionObserver.WriteObserver
-
writeFailed
public void writeFailed(java.lang.Throwable cause)
Description copied from interface:ConnectionObserver.WriteObserver
Callback when the write operation fails with anerror
.- Specified by:
writeFailed
in interfaceConnectionObserver.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 interfaceConnectionObserver.WriteObserver
-
writeCancelled
public void writeCancelled()
Description copied from interface:ConnectionObserver.WriteObserver
Callback when the write operation is cancelled.- Specified by:
writeCancelled
in interfaceConnectionObserver.WriteObserver
-
-