Package io.servicetalk.transport.netty.internal

Class NoopTransportObserver.NoopStreamObserver

java.lang.Object

io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopStreamObserver

All Implemented Interfaces:

ConnectionObserver.StreamObserver

Enclosing class:

NoopTransportObserver

public static final class NoopTransportObserver.NoopStreamObserver
extends Object
implements ConnectionObserver.StreamObserver

Noop version of ConnectionObserver.StreamObserver.

Field Summary

Fields

Modifier and Type	Field	Description
static final ConnectionObserver.StreamObserver	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	streamClosed()	Callback when the stream is closed.
void	streamClosed(Throwable error)	Callback when the stream is closed due to an error.
ConnectionObserver.DataObserver	streamEstablished()	Callback when the stream is established and ready to be used.
void	streamIdAssigned(long streamId)	Callback when a streamId is assigned.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final ConnectionObserver.StreamObserver INSTANCE

Method Details

streamIdAssigned

public void streamIdAssigned(long streamId)

Description copied from interface: ConnectionObserver.StreamObserver

Callback when a streamId is assigned.

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

Specified by:

streamIdAssigned in interface ConnectionObserver.StreamObserver

Parameters:

streamId - assigned stream identifier

streamEstablished

public ConnectionObserver.DataObserver streamEstablished()

Description copied from interface: ConnectionObserver.StreamObserver

Callback when the stream is established and ready to be used. It may or may not have an already assigned streamId at the time.

Specified by:

streamEstablished in interface ConnectionObserver.StreamObserver

Returns:

a new ConnectionObserver.DataObserver that provides visibility into read and write events

See Also:

• ConnectionObserver.StreamObserver.streamIdAssigned(long)

streamClosed

public void streamClosed(Throwable error)

Description copied from interface: ConnectionObserver.StreamObserver

Callback when the stream is closed due to an error.

Specified by:

streamClosed in interface ConnectionObserver.StreamObserver

Parameters:

error - an occurred error

streamClosed

public void streamClosed()

Description copied from interface: ConnectionObserver.StreamObserver

Callback when the stream is closed.

Specified by:

streamClosed in interface ConnectionObserver.StreamObserver