Package io.servicetalk.transport.api
Interface ConnectionObserver.ReadObserver
-
- All Known Implementing Classes:
NoopTransportObserver.NoopReadObserver
- Enclosing interface:
- ConnectionObserver
public static interface ConnectionObserver.ReadObserverAn observer interface that provides visibility into read events.Either
readComplete()orreadFailed(Throwable)will be invoked to signal when a read operation terminates.readCancelled()is also a terminal signal for the read operation, however it may be invoked concurrently withreadComplete()orreadFailed(Throwable).
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voiditemRead()Invokes when a new item is read.voidreadCancelled()Callback when the read operation is cancelled.voidreadComplete()Callback when the entire read operation completes successfully.voidreadFailed(java.lang.Throwable cause)Callback when the read operation fails with anerror.voidrequestedToRead(long n)Callback when new items are requested to read.
-
-
-
Method Detail
-
requestedToRead
void requestedToRead(long n)
Callback when new items are requested to read.- Parameters:
n- number of requested items to read
-
itemRead
void itemRead()
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.
-
readFailed
void readFailed(java.lang.Throwable cause)
Callback when the read operation fails with anerror.- Parameters:
cause-Throwablethat terminated the read
-
readComplete
void readComplete()
Callback when the entire read operation completes successfully.
-
readCancelled
void readCancelled()
Callback when the read operation is cancelled.
-
-