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

      void streamIdAssigned(long streamId)
      Callback when a streamId 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 assigned streamId at the time.
      Returns:
      a new ConnectionObserver.DataObserver that provides visibility into read and write events
      See Also:

    • streamClosed

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

    • streamClosed

      void streamClosed()
      Callback when the stream is closed.