in folsom/src/main/java/com/spotify/folsom/retry/RetryingClient.java [48:60]
public <T> CompletionStage<T> send(final Request<T> request) {
final CompletionStage<T> future = delegate.send(request);
return CompletableFutures.exceptionallyCompose(
future,
e -> {
e = unwrap(e);
if (e instanceof MemcacheClosedException && delegate.isConnected()) {
return delegate.send(request);
} else {
return CompletableFutures.exceptionallyCompletedFuture(e);
}
});
}