public static final class NoopTransportObserver.NoopWriteObserver extends java.lang.Object implements ConnectionObserver.WriteObserver
ConnectionObserver.WriteObserver
.Modifier and Type | Field and Description |
---|---|
static ConnectionObserver.WriteObserver |
INSTANCE |
Modifier and Type | Method and 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 . |
public static final ConnectionObserver.WriteObserver INSTANCE
public void requestedToWrite(long n)
ConnectionObserver.WriteObserver
requestedToWrite
in interface ConnectionObserver.WriteObserver
n
- number of requested items to writepublic void itemReceived()
ConnectionObserver.WriteObserver
Content of the received items should be inspected at the higher level API when these items are produced.
itemReceived
in interface ConnectionObserver.WriteObserver
public void onFlushRequest()
ConnectionObserver.WriteObserver
onFlushRequest
in interface ConnectionObserver.WriteObserver
public void itemWritten()
ConnectionObserver.WriteObserver
Content of the written items should be inspected at the higher level API when these items are produced.
itemWritten
in interface ConnectionObserver.WriteObserver
public void writeFailed(java.lang.Throwable cause)
ConnectionObserver.WriteObserver
error
.writeFailed
in interface ConnectionObserver.WriteObserver
cause
- Throwable
that terminated the writepublic void writeComplete()
ConnectionObserver.WriteObserver
writeComplete
in interface ConnectionObserver.WriteObserver
public void writeCancelled()
ConnectionObserver.WriteObserver
writeCancelled
in interface ConnectionObserver.WriteObserver