Package reactor.netty

Interface ConnectionObserver

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ConnectionObserver

Event listeners for connection lifecycle. A normal event cycle is as follows :

1. onUncaughtException
2. onStateChange

Since:

0.8

Author:

Stephane Maldini

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ConnectionObserver.State	A marker interface for various state signals used in onStateChange(Connection, State)

Method Summary

Modifier and Type	Method	Description
default Context	currentContext()	Connection listener Context.
static ConnectionObserver	emptyListener()	Return a noop connection listener.
void	onStateChange(Connection connection, ConnectionObserver.State newState)	React on connection state change (e.g.
default void	onUncaughtException(Connection connection, Throwable error)	React on connection fatal error, will request a disconnecting state change by default.
default ConnectionObserver	then(ConnectionObserver other)	Chain together another ConnectionObserver.

Method Details

emptyListener

static ConnectionObserver emptyListener()

Return a noop connection listener.

Returns:

a noop connection listener

currentContext

default Context currentContext()

Connection listener Context.

Returns:

current Context or Context.empty()

onUncaughtException

default void onUncaughtException(Connection connection,
 Throwable error)

React on connection fatal error, will request a disconnecting state change by default. It should only catch exceptions that can't be consumed by a NettyInbound.receive() subscriber.

Parameters:

connection - the remote connection

error - the failing cause

onStateChange

void onStateChange(Connection connection,
 ConnectionObserver.State newState)

React on connection state change (e.g. http request or response).

Parameters:

connection - the connection reference

newState - the new State

then

default ConnectionObserver then(ConnectionObserver other)

Chain together another ConnectionObserver.

Parameters:

other - the next ConnectionObserver

Returns:

a new composite ConnectionObserver