code: private void bodyConsumerError(Throwable cause) {
      BodyConsumer consumer = bodyConsumer;
      bodyConsumer = null;
      consumer.handleError(cause);
    }
docs: Calls {@link BodyConsumer#handleError(Throwable)}. The current
  bodyConsumer will be set to {@code null} after the call.