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 Details

    • streamIdAssigned

      default void streamIdAssigned(long streamId)
      Callback when a streamId is assigned.

      The stream identifier may be deferred until after the first write is made on a newly established stream.

      Parameters:
      streamId - the assigned stream identifier

    • streamEstablished

      default ConnectionObserver.DataObserver streamEstablished()
      Callback when the stream is established and ready to be used.

      It may or may not have an already assigned streamId at this time.

      Returns:
      a new ConnectionObserver.DataObserver that provides visibility into read and write events
      See Also:

    • streamClosed

      default void streamClosed(Throwable error)
      Callback when the stream is closed due to an error.
      Parameters:
      error - the error that occurred

    • streamClosed

      default void streamClosed()
      Callback when the stream is closed.