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);   }
@Override @Test public void testReconnectConnection() { final ClientActorBehavior<BackendInfo> behavior = mock(ClientActorBehavior.class); connection.lockedReconnect(behavior, mock(RequestException.class)); verify(behavior).reconnectConnection(same(connection), any(ReconnectingClientConnection.class)); }