src/main/java/com/linecorp/armeria/client/HttpConfigurator.java
/**
         * Waits until the upgrade response is received, and performs the final configuration of the pipeline
         * based on the upgrade result.
         */
Waits until the upgrade response is received, and performs the final configuration of the pipeline
based on the upgrade result.
Waits until the upgrade response is received and performs the final configuration of the pipeline based on the upgrade result .
@Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            if (!receivedUpgradeRes && msg instanceof FullHttpResponse) {
                final FullHttpResponse res = (FullHttpResponse) msg;
                final HttpHeaders headers = res.headers();
                final String streamId = headers.get(ExtensionHeaderNames.STREAM_ID.text());
                if (streamId == null || "1".equals(streamId)) {
                    receivedUpgradeRes = true;
                    onUpgradeResponse(ctx, res);
                    return;
                }
            }
            ctx.fireChannelRead(msg);
        }
@ Override public void channelRead ( ChannelHandlerContext ctx , Object msg ) throws Exception { if ( ! receivedUpgradeRes && msg instanceof FullHttpResponse ) { final FullHttpResponse res = ( FullHttpResponse ) msg ; final HttpHeaders headers = res . headers ( ) ; final String streamId = headers . get ( ExtensionHeaderNames . STREAM_ID . text ( ) ) ; if ( streamId == null || "1" . equals ( streamId ) ) { receivedUpgradeRes = true ; onUpgradeResponse ( ctx , res ) ; return ; } } ctx . fireChannelRead ( msg ) ; }
Waits until the upgrade response is received, and performs the final configuration of the pipeline
 based on the upgrade result.
Waits until the upgrade response is received and performs the final configuration of the pipeline based on the upgrade result .
// Received the response for the upgrade request sent in channelActive().