Package io.servicetalk.transport.api
Interface ConnectionObserver.StreamObserver
-
- All Known Implementing Classes:
NoopTransportObserver.NoopStreamObserver
- Enclosing interface:
- ConnectionObserver
public static interface ConnectionObserver.StreamObserverAn observer interface that provides visibility into stream events.Either
streamClosed()orstreamClosed(Throwable)will be invoked to signal when a stream is closed.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidstreamClosed()Callback when the stream is closed.voidstreamClosed(java.lang.Throwable error)Callback when the stream is closed due to anerror.ConnectionObserver.DataObserverstreamEstablished()Callback when the stream is established and ready.
-
-
-
Method Detail
-
streamEstablished
ConnectionObserver.DataObserver streamEstablished()
Callback when the stream is established and ready.- Returns:
- a new
ConnectionObserver.DataObserverthat provides visibility into read and write events
-
streamClosed
void streamClosed(java.lang.Throwable error)
Callback when the stream is closed due to anerror.- Parameters:
error- an occurred error
-
streamClosed
void streamClosed()
Callback when the stream is closed.
-
-