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 follow :

1. onUncaughtException
2. onStateChange

Since:

0.8

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
default reactor.util.context.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, java.lang.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 Detail

emptyListener

static ConnectionObserver emptyListener()

Return a noop connection listener

Returns:

a noop connection listener

currentContext

default reactor.util.context.Context currentContext()

Connection listener Context

Returns:

current Context or Context.empty()

onUncaughtException

default void onUncaughtException(Connection connection,
                                 java.lang.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