class ConnectedClientConnection extends AbstractReceivingClientConnection<T> {

    @Override
    ClientActorBehavior<T> lockedReconnect(final ClientActorBehavior<T> current, final RequestException cause) {
        final ReconnectingClientConnection<T> next = new ReconnectingClientConnection<>(this, cause);
        setForwarder(new SimpleReconnectForwarder(next));
        current.reconnectConnection(this, next);
        return current;
    }

      ConnectedClientConnection(final AbstractClientConnection<T> oldConnection, final T newBackend);

}