Package io.servicetalk.transport.api
Interface ConnectionObserver.StreamObserver
- All Known Implementing Classes:
NoopTransportObserver.NoopStreamObserver
- Enclosing interface:
- ConnectionObserver
public static interface ConnectionObserver.StreamObserver
An observer interface that provides visibility into stream events.
Either streamClosed()
or streamClosed(Throwable)
will be invoked to signal when a stream is
closed.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Callback when the stream is closed.void
streamClosed
(Throwable error) Callback when the stream is closed due to anerror
.Callback when the stream is established and ready to be used.void
streamIdAssigned
(long streamId) Callback when astreamId
is assigned.
-
Method Details
-
streamIdAssigned
void streamIdAssigned(long streamId) Callback when astreamId
is assigned.Stream identifier may be deferred until after the first write is made on a newly established stream.
- Parameters:
streamId
- assigned stream identifier
-
streamEstablished
ConnectionObserver.DataObserver streamEstablished()Callback when the stream is established and ready to be used. It may or may not have an already assignedstreamId
at the time.- Returns:
- a new
ConnectionObserver.DataObserver
that provides visibility into read and write events - See Also:
-
streamClosed
Callback when the stream is closed due to anerror
.- Parameters:
error
- an occurred error
-
streamClosed
void streamClosed()Callback when the stream is closed.
-