public static interface ConnectionObserver.WriteObserver
Either writeComplete()
or writeFailed(Throwable)
will be invoked to signal when a write
operation terminates. writeCancelled()
is also a terminal signal for the write operation, however it may
be invoked concurrently with writeComplete()
or writeFailed(Throwable)
.
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 . |
void requestedToWrite(long n)
n
- number of requested items to writevoid itemReceived()
Content of the received items should be inspected at the higher level API when these items are produced.
void onFlushRequest()
void itemWritten()
Content of the written items should be inspected at the higher level API when these items are produced.
void writeFailed(java.lang.Throwable cause)
error
.cause
- Throwable
that terminated the writevoid writeComplete()
void writeCancelled()