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.StreamObserver
INSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
streamClosed()
Callback when the stream is closed.void
streamClosed(java.lang.Throwable error)
Callback when the stream is closed due to anerror
.ConnectionObserver.DataObserver
streamEstablished()
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.StreamObserver
Callback when the stream is established and ready.- Specified by:
streamEstablished
in interfaceConnectionObserver.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 anerror
.- Specified by:
streamClosed
in interfaceConnectionObserver.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 interfaceConnectionObserver.StreamObserver
-
-