handleResponse() — netty Function Reference

Architecture documentation for the handleResponse() function in HttpProxyHandler.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ handleResponse() — netty Function Reference

Dependency Diagram

graph TD
  030cbe3b_a8fe_f70a_8682_b62d05d3b14c["handleResponse()"]
  9f67123e_d153_cb48_a674_901255ce7066["HttpProxyHandler"]
  030cbe3b_a8fe_f70a_8682_b62d05d3b14c -->|defined in| 9f67123e_d153_cb48_a674_901255ce7066
  e0b0ece8_dbb9_37f2_9c43_0afc38f40f18["HttpProxyConnectException()"]
  030cbe3b_a8fe_f70a_8682_b62d05d3b14c -->|calls| e0b0ece8_dbb9_37f2_9c43_0afc38f40f18
  style 030cbe3b_a8fe_f70a_8682_b62d05d3b14c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler-proxy/src/main/java/io/netty/handler/proxy/HttpProxyHandler.java lines 195–217

    @Override
    protected boolean handleResponse(ChannelHandlerContext ctx, Object response) throws Exception {
        if (response instanceof HttpResponse) {
            if (status != null) {
                throw new HttpProxyConnectException(exceptionMessage("too many responses"), /*headers=*/ null);
            }
            HttpResponse res = (HttpResponse) response;
            status = res.status();
            inboundHeaders = res.headers();
        }

        boolean finished = response instanceof LastHttpContent;
        if (finished) {
            if (status == null) {
                throw new HttpProxyConnectException(exceptionMessage("missing response"), inboundHeaders);
            }
            if (status.code() != 200) {
                throw new HttpProxyConnectException(exceptionMessage("status: " + status), inboundHeaders);
            }
        }

        return finished;
    }