io.servicetalk.transport.netty.internal

Class NoopTransportObserver.NoopConnectionObserver

java.lang.Object

io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver

All Implemented Interfaces:

ConnectionObserver

Enclosing class:

NoopTransportObserver

public static final class NoopTransportObserver.NoopConnectionObserver
extends java.lang.Object
implements ConnectionObserver

Noop version of ConnectionObserver.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.transport.api.ConnectionObserver

ConnectionObserver.DataObserver, ConnectionObserver.MultiplexedObserver, ConnectionObserver.ReadObserver, ConnectionObserver.SecurityHandshakeObserver, ConnectionObserver.StreamObserver, ConnectionObserver.WriteObserver

Field Summary

Fields

Modifier and Type	Field and Description
static ConnectionObserver	INSTANCE

Method Summary

Modifier and Type	Method and Description
void	connectionClosed() Callback when the connection is closed.
void	connectionClosed(java.lang.Throwable error) Callback when the connection is closed due to an error.
ConnectionObserver.DataObserver	connectionEstablished(ConnectionInfo info) Callback when a non-multiplexed connection is established and ready.
ConnectionObserver.MultiplexedObserver	multiplexedConnectionEstablished(ConnectionInfo info) Callback when a multiplexed connection is established and ready.
void	onDataRead(int size) Callback when size bytes are read from the connection.
void	onDataWrite(int size) Callback when size bytes are written to the connection.
void	onFlush() Callback when previously written data is flushed to the connection.
ConnectionObserver.SecurityHandshakeObserver	onSecurityHandshake() Callback when a security handshake is initiated.

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 INSTANCE

Method Detail

onDataRead

public void onDataRead(int size)

Description copied from interface: ConnectionObserver

Callback when size bytes are read from the connection.

Specified by:

onDataRead in interface ConnectionObserver

Parameters:

size - size of the data chunk read

onDataWrite

public void onDataWrite(int size)

Description copied from interface: ConnectionObserver

Callback when size bytes are written to the connection.

Specified by:

onDataWrite in interface ConnectionObserver

Parameters:

size - size of the data chunk written

onFlush

public void onFlush()

Description copied from interface: ConnectionObserver

Callback when previously written data is flushed to the connection.

Specified by:

onFlush in interface ConnectionObserver

onSecurityHandshake

public ConnectionObserver.SecurityHandshakeObserver onSecurityHandshake()

Description copied from interface: ConnectionObserver

Callback when a security handshake is initiated.

Specified by:

onSecurityHandshake in interface ConnectionObserver

Returns:

a new ConnectionObserver.SecurityHandshakeObserver that provides visibility into security handshake events

connectionEstablished

public ConnectionObserver.DataObserver connectionEstablished(ConnectionInfo info)

Description copied from interface: ConnectionObserver

Callback when a non-multiplexed connection is established and ready.

Specified by:

connectionEstablished in interface ConnectionObserver

Parameters:

info - ConnectionInfo for the established connection

Returns:

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

multiplexedConnectionEstablished

public ConnectionObserver.MultiplexedObserver multiplexedConnectionEstablished(ConnectionInfo info)

Description copied from interface: ConnectionObserver

Callback when a multiplexed connection is established and ready.

Specified by:

multiplexedConnectionEstablished in interface ConnectionObserver

Parameters:

info - ConnectionInfo for the established connection

Returns:

a new ConnectionObserver.MultiplexedObserver that provides visibility into new streams

connectionClosed

public void connectionClosed(java.lang.Throwable error)

Description copied from interface: ConnectionObserver

Callback when the connection is closed due to an error.

Specified by:

connectionClosed in interface ConnectionObserver

Parameters:

error - an occurred error

connectionClosed

public void connectionClosed()

Description copied from interface: ConnectionObserver

Callback when the connection is closed.

Specified by:

connectionClosed in interface ConnectionObserver