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