code: @Override
    public void channelRead0(ChannelHandlerContext context, O response) throws Exception {
      Envelope envelope = null;
      try {
        envelope = convertResponse(response);
      } catch (ResponseConversionException rce) {
        logger.log(Level.WARNING, "Failed to convert response", rce);
        return;
      }
      EnvelopeFuture<? extends Message> future = inFlightRequests.remove(envelope.getRequestId());
      if (future == null) {
        logger.warning(String.format("Received response from %s for unknown request id: %d",
            channel.remoteAddress(), envelope.getRequestId()));
        return;
      }
      future.setResponse(envelope);
    }
docs: {@inheritDoc}