ReconnectingClientConnection extends AbstractReceivingClientConnection<T> { @Override @SuppressWarnings("checkstyle:hiddenField") ClientActorBehavior<T> lockedReconnect(final ClientActorBehavior<T> current, final RequestException cause) { this.cause = requireNonNull(cause); LOG.warn("Skipping reconnect of already-reconnecting connection {}", this); return current; } ReconnectingClientConnection(final ConnectedClientConnection<T> oldConnection, final RequestException cause);   }
@Override @Test public void testReconnectConnection() { final ClientActorBehavior<BackendInfo> behavior = mock(ClientActorBehavior.class); assertSame(behavior, connection.lockedReconnect(behavior, mock(RequestException.class))); }