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 ofConnectionObserver.StreamObserver.
-
-
Field Summary
Fields Modifier and Type Field Description static ConnectionObserver.StreamObserverINSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidstreamClosed()Callback when the stream is closed.voidstreamClosed(java.lang.Throwable error)Callback when the stream is closed due to anerror.ConnectionObserver.DataObserverstreamEstablished()Callback when the stream is established and ready.
-
-
-
Field Detail
-
INSTANCE
public static final ConnectionObserver.StreamObserver INSTANCE
-
-
Method Detail
-
streamEstablished
public ConnectionObserver.DataObserver streamEstablished()
Description copied from interface:ConnectionObserver.StreamObserverCallback when the stream is established and ready.- Specified by:
streamEstablishedin interfaceConnectionObserver.StreamObserver- Returns:
- a new
ConnectionObserver.DataObserverthat provides visibility into read and write events
-
streamClosed
public void streamClosed(java.lang.Throwable error)
Description copied from interface:ConnectionObserver.StreamObserverCallback when the stream is closed due to anerror.- Specified by:
streamClosedin interfaceConnectionObserver.StreamObserver- Parameters:
error- an occurred error
-
streamClosed
public void streamClosed()
Description copied from interface:ConnectionObserver.StreamObserverCallback when the stream is closed.- Specified by:
streamClosedin interfaceConnectionObserver.StreamObserver
-
-