code: private void handleResponseFailure(long requestId, Throwable t) {
      ContextualFuture future = responseFutures.remove(requestId);
      if (future != null) {
        future.context.executor().execute(() -> future.completeExceptionally(t));
      }
    }
docs: Handles a failure response.