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 java.lang.Object
implements ConnectionObserver.StreamObserver

Noop version of ConnectionObserver.StreamObserver.

Field Summary

Fields

Modifier and Type	Field and Description
static ConnectionObserver.StreamObserver	INSTANCE

Method Summary

Modifier and Type	Method and Description
void	streamClosed() Callback when the stream is closed.
void	streamClosed(java.lang.Throwable error) Callback when the stream is closed due to an error.
ConnectionObserver.DataObserver	streamEstablished() Callback when the stream is established and ready.

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final ConnectionObserver.StreamObserver INSTANCE

Method Detail

streamEstablished

public ConnectionObserver.DataObserver streamEstablished()

Description copied from interface: ConnectionObserver.StreamObserver

Callback when the stream is established and ready.

Specified by:

streamEstablished in interface ConnectionObserver.StreamObserver

Returns:

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

streamClosed

public void streamClosed(java.lang.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