HttpDownloadHandler.java 文件源码

@Override
protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
  checkState(userPromise != null, "response before request");
  if (msg instanceof HttpResponse) {
    HttpResponse response = (HttpResponse) msg;
    keepAlive = HttpUtil.isKeepAlive((HttpResponse) msg);
    if (!response.status().equals(HttpResponseStatus.OK)) {
      failAndReset(
          new HttpException(
              response.status(), "Download failed with Status: " + response.status(), null),
          ctx);
    }
  } else if (msg instanceof HttpContent) {
    ByteBuf content = ((HttpContent) msg).content();
    content.readBytes(out, content.readableBytes());
    if (msg instanceof LastHttpContent) {
      succeedAndReset(ctx);
    }
  } else {
    failAndReset(
        new IllegalArgumentException(
            "Unsupported message type: " + StringUtil.simpleClassName(msg)),
        ctx);
  }
}