// Call initial shutdown listener
callShutdownListener(initialResource,
initialResource instanceof ConnectionHandler ? connectionShutdownSignal()
: channelShutdownSignal());
if (expectedResumes > 0)
waiter.await(1000);
Thread.sleep(100);
}
/** Mock recovery for the resource, with recovery attempts failing because of {@code e}. */
abstract void mockRecovery(Exception e, RetryableResource retryableResource) throws IOException;