public class io.micronaut.http.netty.stream.HttpStreamsServerHandler extends io.micronaut.http.netty.stream.HttpStreamsHandler<io.netty.handler.codec.http.HttpRequest, io.netty.handler.codec.http.HttpResponse>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.micronaut.http.netty.stream.HttpStreamsServerHandler
  super_class: io.micronaut.http.netty.stream.HttpStreamsHandler
{
  private io.netty.handler.codec.http.HttpRequest lastRequest;
    descriptor: Lio/netty/handler/codec/http/HttpRequest;
    flags: (0x0002) ACC_PRIVATE

  private io.micronaut.http.netty.stream.HttpStreamsHandler<io.netty.handler.codec.http.HttpRequest, io.netty.handler.codec.http.HttpResponse>.Outgoing webSocketResponse;
    descriptor: Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/micronaut/http/netty/stream/HttpStreamsHandler<Lio/netty/handler/codec/http/HttpRequest;Lio/netty/handler/codec/http/HttpResponse;>.Outgoing;

  private int inFlight;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private boolean continueExpected;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean sendContinue;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean close;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private final java.util.List<io.netty.channel.ChannelHandler> dependentHandlers;
    descriptor: Ljava/util/List;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/List<Lio/netty/channel/ChannelHandler;>;

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
         0: .line 73
            aload 0 /* this */
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            invokespecial io.micronaut.http.netty.stream.HttpStreamsServerHandler.<init>:(Ljava/util/List;)V
         1: .line 74
            return
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;

  public void <init>(java.util.List<io.netty.channel.ChannelHandler>);
    descriptor: (Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // java.util.List dependentHandlers
         0: .line 86
            aload 0 /* this */
            ldc Lio/netty/handler/codec/http/HttpRequest;
            ldc Lio/netty/handler/codec/http/HttpResponse;
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.<init>:(Ljava/lang/Class;Ljava/lang/Class;)V
         1: .line 60
            aload 0 /* this */
            aconst_null
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
         2: .line 61
            aload 0 /* this */
            aconst_null
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.webSocketResponse:Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;
         3: .line 62
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
         4: .line 63
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
         5: .line 64
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.sendContinue:Z
         6: .line 65
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.close:Z
         7: .line 87
            aload 0 /* this */
            aload 1 /* dependentHandlers */
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.dependentHandlers:Ljava/util/List;
         8: .line 88
            return
        end local 1 // java.util.List dependentHandlers
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    9     0               this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    9     1  dependentHandlers  Ljava/util/List<Lio/netty/channel/ChannelHandler;>;
    Signature: (Ljava/util/List<Lio/netty/channel/ChannelHandler;>;)V
    MethodParameters:
                   Name  Flags
      dependentHandlers  

  protected boolean hasBody(io.netty.handler.codec.http.HttpRequest);
    descriptor: (Lio/netty/handler/codec/http/HttpRequest;)Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.handler.codec.http.HttpRequest request
         0: .line 94
            aload 1 /* request */
            iconst_0
            invokestatic io.netty.handler.codec.http.HttpUtil.getContentLength:(Lio/netty/handler/codec/http/HttpMessage;I)I
            ifne 1
            aload 1 /* request */
            invokestatic io.netty.handler.codec.http.HttpUtil.isTransferEncodingChunked:(Lio/netty/handler/codec/http/HttpMessage;)Z
            ifne 1
            iconst_0
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_1
            ireturn
        end local 1 // io.netty.handler.codec.http.HttpRequest request
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    2     1  request  Lio/netty/handler/codec/http/HttpRequest;
    MethodParameters:
         Name  Flags
      request  

  protected io.netty.handler.codec.http.HttpRequest createEmptyMessage(io.netty.handler.codec.http.HttpRequest);
    descriptor: (Lio/netty/handler/codec/http/HttpRequest;)Lio/netty/handler/codec/http/HttpRequest;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.handler.codec.http.HttpRequest request
         0: .line 99
            new io.micronaut.http.netty.stream.EmptyHttpRequest
            dup
            aload 1 /* request */
            invokespecial io.micronaut.http.netty.stream.EmptyHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;)V
            areturn
        end local 1 // io.netty.handler.codec.http.HttpRequest request
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    1     1  request  Lio/netty/handler/codec/http/HttpRequest;
    MethodParameters:
         Name  Flags
      request  

  protected io.netty.handler.codec.http.HttpRequest createStreamedMessage(io.netty.handler.codec.http.HttpRequest, org.reactivestreams.Publisher<? extends io.netty.handler.codec.http.HttpContent>);
    descriptor: (Lio/netty/handler/codec/http/HttpRequest;Lorg/reactivestreams/Publisher;)Lio/netty/handler/codec/http/HttpRequest;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.handler.codec.http.HttpRequest httpRequest
        start local 2 // org.reactivestreams.Publisher stream
         0: .line 104
            new io.micronaut.http.netty.stream.DelegateStreamedHttpRequest
            dup
            aload 1 /* httpRequest */
            aload 2 /* stream */
            invokespecial io.micronaut.http.netty.stream.DelegateStreamedHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;Lorg/reactivestreams/Publisher;)V
            areturn
        end local 2 // org.reactivestreams.Publisher stream
        end local 1 // io.netty.handler.codec.http.HttpRequest httpRequest
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    1     0         this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    1     1  httpRequest  Lio/netty/handler/codec/http/HttpRequest;
            0    1     2       stream  Lorg/reactivestreams/Publisher<+Lio/netty/handler/codec/http/HttpContent;>;
    Signature: (Lio/netty/handler/codec/http/HttpRequest;Lorg/reactivestreams/Publisher<+Lio/netty/handler/codec/http/HttpContent;>;)Lio/netty/handler/codec/http/HttpRequest;
    MethodParameters:
             Name  Flags
      httpRequest  
      stream       

  public void channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
         0: .line 111
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
         1: .line 112
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.sendContinue:Z
         2: .line 114
            aload 2 /* msg */
            instanceof io.netty.handler.codec.http.HttpRequest
            ifeq 7
         3: .line 115
            aload 2 /* msg */
            checkcast io.netty.handler.codec.http.HttpRequest
            astore 3 /* request */
        start local 3 // io.netty.handler.codec.http.HttpRequest request
         4: .line 116
            aload 0 /* this */
            aload 3 /* request */
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
         5: .line 117
            aload 3 /* request */
            invokestatic io.netty.handler.codec.http.HttpUtil.is100ContinueExpected:(Lio/netty/handler/codec/http/HttpMessage;)Z
            ifeq 7
         6: .line 118
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
        end local 3 // io.netty.handler.codec.http.HttpRequest request
         7: .line 121
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* msg */
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.channelRead:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
         8: .line 122
            return
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    9     1      ctx  Lio/netty/channel/ChannelHandlerContext;
            0    9     2      msg  Ljava/lang/Object;
            4    7     3  request  Lio/netty/handler/codec/http/HttpRequest;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   
      msg   

  protected void receivedInMessage(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 126
            aload 0 /* this */
            dup
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
            iconst_1
            iadd
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
         1: .line 127
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    2     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    MethodParameters:
      Name  Flags
      ctx   

  protected void sentOutMessage(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 131
            aload 0 /* this */
            dup
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
            iconst_1
            isub
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
         1: .line 132
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
            iconst_1
            if_icmpne 5
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
            ifeq 5
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.sendContinue:Z
            ifeq 5
         2: .line 133
            aload 1 /* ctx */
            new io.netty.handler.codec.http.DefaultFullHttpResponse
            dup
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            invokeinterface io.netty.handler.codec.http.HttpRequest.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
            getstatic io.netty.handler.codec.http.HttpResponseStatus.CONTINUE:Lio/netty/handler/codec/http/HttpResponseStatus;
            invokespecial io.netty.handler.codec.http.DefaultFullHttpResponse.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpResponseStatus;)V
            invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
            pop
         3: .line 134
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.sendContinue:Z
         4: .line 135
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
         5: .line 138
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.close:Z
            ifeq 7
         6: .line 139
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.close:()Lio/netty/channel/ChannelFuture;
            pop
         7: .line 141
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    8     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    MethodParameters:
      Name  Flags
      ctx   

  protected void unbufferedWrite(io.netty.channel.ChannelHandlerContext, io.micronaut.http.netty.stream.HttpStreamsHandler<io.netty.handler.codec.http.HttpRequest, io.netty.handler.codec.http.HttpResponse>.Outgoing);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing out
         0: .line 146
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            instanceof io.micronaut.http.netty.stream.WebSocketHttpResponse
            ifeq 6
         1: .line 147
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            instanceof io.netty.handler.codec.http.FullHttpRequest
            ifne 2
            aload 0 /* this */
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.hasBody:(Lio/netty/handler/codec/http/HttpRequest;)Z
            ifne 4
         2: .line 148
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* out */
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.handleWebSocketResponse:(Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
         3: .line 149
            goto 22
         4: .line 152
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* out */
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.webSocketResponse:Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;
         5: .line 154
            goto 22
         6: .line 155
      StackMap locals:
      StackMap stack:
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            checkcast io.netty.handler.codec.http.HttpResponse
            invokeinterface io.netty.handler.codec.http.HttpResponse.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.netty.handler.codec.http.HttpHeaderNames.CONNECTION:Lio/netty/util/AsciiString;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.get:(Ljava/lang/CharSequence;)Ljava/lang/String;
            astore 3 /* connection */
        start local 3 // java.lang.String connection
         7: .line 156
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            invokeinterface io.netty.handler.codec.http.HttpRequest.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
            invokevirtual io.netty.handler.codec.http.HttpVersion.isKeepAliveDefault:()Z
            ifeq 11
         8: .line 157
            ldc "close"
            aload 3 /* connection */
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 13
         9: .line 158
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.close:Z
        10: .line 160
            goto 13
        11: .line 161
      StackMap locals: java.lang.String
      StackMap stack:
            ldc "keep-alive"
            aload 3 /* connection */
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifne 13
        12: .line 162
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.close:Z
        13: .line 165
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
            iconst_1
            if_icmpne 17
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
            ifeq 17
        14: .line 166
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            iconst_0
            invokestatic io.netty.handler.codec.http.HttpUtil.setKeepAlive:(Lio/netty/handler/codec/http/HttpMessage;Z)V
        15: .line 167
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.close:Z
        16: .line 168
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
        17: .line 172
      StackMap locals:
      StackMap stack:
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            invokestatic io.netty.handler.codec.http.HttpUtil.isContentLengthSet:(Lio/netty/handler/codec/http/HttpMessage;)Z
            ifne 21
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            invokestatic io.netty.handler.codec.http.HttpUtil.isTransferEncodingChunked:(Lio/netty/handler/codec/http/HttpMessage;)Z
            ifne 21
        18: .line 173
            aload 0 /* this */
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            checkcast io.netty.handler.codec.http.HttpResponse
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.canHaveBody:(Lio/netty/handler/codec/http/HttpResponse;)Z
            ifeq 21
        19: .line 174
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            iconst_0
            invokestatic io.netty.handler.codec.http.HttpUtil.setKeepAlive:(Lio/netty/handler/codec/http/HttpMessage;Z)V
        20: .line 175
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.close:Z
        21: .line 177
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 2 /* out */
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.unbufferedWrite:(Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
        end local 3 // java.lang.String connection
        22: .line 179
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing out
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   23     0        this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0   23     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            0   23     2         out  Lio/micronaut/http/netty/stream/HttpStreamsHandler<Lio/netty/handler/codec/http/HttpRequest;Lio/netty/handler/codec/http/HttpResponse;>.Outgoing;
            7   22     3  connection  Ljava/lang/String;
    Signature: (Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler<Lio/netty/handler/codec/http/HttpRequest;Lio/netty/handler/codec/http/HttpResponse;>.Outgoing;)V
    MethodParameters:
      Name  Flags
      ctx   
      out   

  protected boolean isValidOutMessage(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // java.lang.Object msg
         0: .line 183
            aload 1 /* msg */
            instanceof io.netty.handler.codec.http.FullHttpResponse
            ifne 1
            aload 1 /* msg */
            instanceof io.micronaut.http.netty.stream.StreamedHttpResponse
            ifne 1
            aload 1 /* msg */
            instanceof io.micronaut.http.netty.stream.WebSocketHttpResponse
            ifne 1
            iconst_0
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_1
            ireturn
        end local 1 // java.lang.Object msg
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    2     1   msg  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      msg   

  private boolean canHaveBody(io.netty.handler.codec.http.HttpResponse);
    descriptor: (Lio/netty/handler/codec/http/HttpResponse;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.handler.codec.http.HttpResponse message
         0: .line 187
            aload 1 /* message */
            invokeinterface io.netty.handler.codec.http.HttpResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
            astore 2 /* status */
        start local 2 // io.netty.handler.codec.http.HttpResponseStatus status
         1: .line 190
            aload 2 /* status */
            getstatic io.netty.handler.codec.http.HttpResponseStatus.CONTINUE:Lio/netty/handler/codec/http/HttpResponseStatus;
            if_acmpeq 4
            aload 2 /* status */
            getstatic io.netty.handler.codec.http.HttpResponseStatus.SWITCHING_PROTOCOLS:Lio/netty/handler/codec/http/HttpResponseStatus;
            if_acmpeq 4
         2: .line 191
            aload 2 /* status */
            getstatic io.netty.handler.codec.http.HttpResponseStatus.PROCESSING:Lio/netty/handler/codec/http/HttpResponseStatus;
            if_acmpeq 4
            aload 2 /* status */
            getstatic io.netty.handler.codec.http.HttpResponseStatus.NO_CONTENT:Lio/netty/handler/codec/http/HttpResponseStatus;
            if_acmpeq 4
         3: .line 192
            aload 2 /* status */
            getstatic io.netty.handler.codec.http.HttpResponseStatus.NOT_MODIFIED:Lio/netty/handler/codec/http/HttpResponseStatus;
            if_acmpne 5
         4: .line 190
      StackMap locals: io.netty.handler.codec.http.HttpResponseStatus
      StackMap stack:
            iconst_0
            goto 6
      StackMap locals:
      StackMap stack:
         5: iconst_1
      StackMap locals:
      StackMap stack: int
         6: ireturn
        end local 2 // io.netty.handler.codec.http.HttpResponseStatus status
        end local 1 // io.netty.handler.codec.http.HttpResponse message
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    7     1  message  Lio/netty/handler/codec/http/HttpResponse;
            1    7     2   status  Lio/netty/handler/codec/http/HttpResponseStatus;
    MethodParameters:
         Name  Flags
      message  

  protected void consumedInMessage(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 197
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.webSocketResponse:Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;
            ifnull 3
         1: .line 198
            aload 0 /* this */
            aload 1 /* ctx */
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.webSocketResponse:Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.handleWebSocketResponse:(Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
         2: .line 199
            aload 0 /* this */
            aconst_null
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.webSocketResponse:Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;
         3: .line 201
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    4     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    MethodParameters:
      Name  Flags
      ctx   

  private void handleWebSocketResponse(io.netty.channel.ChannelHandlerContext, io.micronaut.http.netty.stream.HttpStreamsHandler<io.netty.handler.codec.http.HttpRequest, io.netty.handler.codec.http.HttpResponse>.Outgoing);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=8, args_size=3
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing out
         0: .line 204
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.message:Lio/netty/handler/codec/http/HttpMessage;
            checkcast io.micronaut.http.netty.stream.WebSocketHttpResponse
            astore 3 /* response */
        start local 3 // io.micronaut.http.netty.stream.WebSocketHttpResponse response
         1: .line 205
            aload 3 /* response */
            invokeinterface io.micronaut.http.netty.stream.WebSocketHttpResponse.handshakerFactory:()Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshakerFactory;
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            invokevirtual io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory.newHandshaker:(Lio/netty/handler/codec/http/HttpRequest;)Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
            astore 4 /* handshaker */
        start local 4 // io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker handshaker
         2: .line 207
            aload 4 /* handshaker */
            ifnonnull 12
         3: .line 208
            new io.netty.handler.codec.http.DefaultFullHttpResponse
            dup
         4: .line 209
            getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_1:Lio/netty/handler/codec/http/HttpVersion;
         5: .line 210
            getstatic io.netty.handler.codec.http.HttpResponseStatus.UPGRADE_REQUIRED:Lio/netty/handler/codec/http/HttpResponseStatus;
         6: .line 208
            invokespecial io.netty.handler.codec.http.DefaultFullHttpResponse.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpResponseStatus;)V
            astore 5 /* res */
        start local 5 // io.netty.handler.codec.http.HttpResponse res
         7: .line 211
            aload 5 /* res */
            invokeinterface io.netty.handler.codec.http.HttpResponse.headers:()Lio/netty/handler/codec/http/HttpHeaders;
            getstatic io.netty.handler.codec.http.HttpHeaderNames.SEC_WEBSOCKET_VERSION:Lio/netty/util/AsciiString;
            getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V13:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
            invokevirtual io.netty.handler.codec.http.websocketx.WebSocketVersion.toHttpHeaderValue:()Ljava/lang/String;
            invokevirtual io.netty.handler.codec.http.HttpHeaders.set:(Ljava/lang/CharSequence;Ljava/lang/Object;)Lio/netty/handler/codec/http/HttpHeaders;
            pop
         8: .line 212
            aload 5 /* res */
            lconst_0
            invokestatic io.netty.handler.codec.http.HttpUtil.setContentLength:(Lio/netty/handler/codec/http/HttpMessage;J)V
         9: .line 213
            aload 0 /* this */
            aload 1 /* ctx */
            new io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing
            dup
            aload 0 /* this */
            aload 5 /* res */
            aload 2 /* out */
            getfield io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.promise:Lio/netty/channel/ChannelPromise;
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing.<init>:(Lio/micronaut/http/netty/stream/HttpStreamsHandler;Lio/netty/handler/codec/http/HttpMessage;Lio/netty/channel/ChannelPromise;)V
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.unbufferedWrite:(Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler$Outgoing;)V
        10: .line 214
            aload 3 /* response */
            new io.micronaut.http.netty.reactive.CancelledSubscriber
            dup
            invokespecial io.micronaut.http.netty.reactive.CancelledSubscriber.<init>:()V
            invokeinterface io.micronaut.http.netty.stream.WebSocketHttpResponse.subscribe:(Lorg/reactivestreams/Subscriber;)V
        end local 5 // io.netty.handler.codec.http.HttpResponse res
        11: .line 215
            goto 21
        12: .line 217
      StackMap locals: io.micronaut.http.netty.stream.WebSocketHttpResponse io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker
      StackMap stack:
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            astore 5 /* pipeline */
        start local 5 // io.netty.channel.ChannelPipeline pipeline
        13: .line 218
            new io.micronaut.http.netty.reactive.HandlerPublisher
            dup
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            ldc Lio/netty/handler/codec/http/websocketx/WebSocketFrame;
            invokespecial io.micronaut.http.netty.reactive.HandlerPublisher.<init>:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Class;)V
            astore 6 /* publisher */
        start local 6 // io.micronaut.http.netty.reactive.HandlerPublisher publisher
        14: .line 219
            new io.micronaut.http.netty.reactive.HandlerSubscriber
            dup
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            invokespecial io.micronaut.http.netty.reactive.HandlerSubscriber.<init>:(Lio/netty/util/concurrent/EventExecutor;)V
            astore 7 /* subscriber */
        start local 7 // io.micronaut.http.netty.reactive.HandlerSubscriber subscriber
        15: .line 220
            aload 5 /* pipeline */
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
            ldc "websocket-subscriber"
            aload 7 /* subscriber */
            invokeinterface io.netty.channel.ChannelPipeline.addAfter:(Lio/netty/util/concurrent/EventExecutorGroup;Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
        16: .line 221
            aload 5 /* pipeline */
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.executor:()Lio/netty/util/concurrent/EventExecutor;
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
            ldc "websocket-publisher"
            aload 6 /* publisher */
            invokeinterface io.netty.channel.ChannelPipeline.addAfter:(Lio/netty/util/concurrent/EventExecutorGroup;Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
        17: .line 224
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.name:()Ljava/lang/String;
            invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
            pop
        18: .line 229
            aload 4 /* handshaker */
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            new io.micronaut.http.netty.stream.EmptyHttpRequest
            dup
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            invokespecial io.micronaut.http.netty.stream.EmptyHttpRequest.<init>:(Lio/netty/handler/codec/http/HttpRequest;)V
            invokevirtual io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker.handshake:(Lio/netty/channel/Channel;Lio/netty/handler/codec/http/FullHttpRequest;)Lio/netty/channel/ChannelFuture;
            pop
        19: .line 232
            aload 3 /* response */
            aload 7 /* subscriber */
            invokeinterface io.micronaut.http.netty.stream.WebSocketHttpResponse.subscribe:(Lorg/reactivestreams/Subscriber;)V
        20: .line 233
            aload 6 /* publisher */
            aload 3 /* response */
            invokevirtual io.micronaut.http.netty.reactive.HandlerPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
        end local 7 // io.micronaut.http.netty.reactive.HandlerSubscriber subscriber
        end local 6 // io.micronaut.http.netty.reactive.HandlerPublisher publisher
        end local 5 // io.netty.channel.ChannelPipeline pipeline
        21: .line 236
      StackMap locals:
      StackMap stack:
            return
        end local 4 // io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker handshaker
        end local 3 // io.micronaut.http.netty.stream.WebSocketHttpResponse response
        end local 2 // io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing out
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   22     0        this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0   22     1         ctx  Lio/netty/channel/ChannelHandlerContext;
            0   22     2         out  Lio/micronaut/http/netty/stream/HttpStreamsHandler<Lio/netty/handler/codec/http/HttpRequest;Lio/netty/handler/codec/http/HttpResponse;>.Outgoing;
            1   22     3    response  Lio/micronaut/http/netty/stream/WebSocketHttpResponse;
            2   22     4  handshaker  Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
            7   11     5         res  Lio/netty/handler/codec/http/HttpResponse;
           13   21     5    pipeline  Lio/netty/channel/ChannelPipeline;
           14   21     6   publisher  Lio/micronaut/http/netty/reactive/HandlerPublisher<Lio/netty/handler/codec/http/websocketx/WebSocketFrame;>;
           15   21     7  subscriber  Lio/micronaut/http/netty/reactive/HandlerSubscriber<Lio/netty/handler/codec/http/websocketx/WebSocketFrame;>;
    Signature: (Lio/netty/channel/ChannelHandlerContext;Lio/micronaut/http/netty/stream/HttpStreamsHandler<Lio/netty/handler/codec/http/HttpRequest;Lio/netty/handler/codec/http/HttpResponse;>.Outgoing;)V
    MethodParameters:
      Name  Flags
      ctx   
      out   

  protected void bodyRequested(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 240
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
            ifeq 6
         1: .line 241
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.inFlight:I
            iconst_1
            if_icmpne 5
         2: .line 242
            aload 1 /* ctx */
            new io.netty.handler.codec.http.DefaultFullHttpResponse
            dup
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.lastRequest:Lio/netty/handler/codec/http/HttpRequest;
            invokeinterface io.netty.handler.codec.http.HttpRequest.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
            getstatic io.netty.handler.codec.http.HttpResponseStatus.CONTINUE:Lio/netty/handler/codec/http/HttpResponseStatus;
            invokespecial io.netty.handler.codec.http.DefaultFullHttpResponse.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpResponseStatus;)V
            invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
            pop
         3: .line 243
            aload 0 /* this */
            iconst_0
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.continueExpected:Z
         4: .line 244
            goto 6
         5: .line 245
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.sendContinue:Z
         6: .line 248
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    7     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    MethodParameters:
      Name  Flags
      ctx   

  protected final boolean isClient();
    descriptor: ()Z
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
         0: .line 252
            iconst_0
            ireturn
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;

  public void handlerRemoved(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 257
            aload 0 /* this */
            aload 1 /* ctx */
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.handlerRemoved:(Lio/netty/channel/ChannelHandlerContext;)V
         1: .line 258
            aload 0 /* this */
            getfield io.micronaut.http.netty.stream.HttpStreamsServerHandler.dependentHandlers:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 6
      StackMap locals: io.micronaut.http.netty.stream.HttpStreamsServerHandler io.netty.channel.ChannelHandlerContext top java.util.Iterator
      StackMap stack:
         2: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.netty.channel.ChannelHandler
            astore 2 /* dependent */
        start local 2 // io.netty.channel.ChannelHandler dependent
         3: .line 260
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            aload 2 /* dependent */
            invokeinterface io.netty.channel.ChannelPipeline.remove:(Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
         4: .line 261
            goto 6
      StackMap locals: io.micronaut.http.netty.stream.HttpStreamsServerHandler io.netty.channel.ChannelHandlerContext io.netty.channel.ChannelHandler java.util.Iterator
      StackMap stack: java.util.NoSuchElementException
         5: pop
        end local 2 // io.netty.channel.ChannelHandler dependent
         6: .line 258
      StackMap locals: io.micronaut.http.netty.stream.HttpStreamsServerHandler io.netty.channel.ChannelHandlerContext top java.util.Iterator
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         7: .line 265
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.micronaut.http.netty.stream.HttpStreamsServerHandler this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    8     0       this  Lio/micronaut/http/netty/stream/HttpStreamsServerHandler;
            0    8     1        ctx  Lio/netty/channel/ChannelHandlerContext;
            3    6     2  dependent  Lio/netty/channel/ChannelHandler;
      Exception table:
        from    to  target  type
           3     4       5  Class java.util.NoSuchElementException
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  public void channelReadComplete(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.channelReadComplete:(Lio/netty/channel/ChannelHandlerContext;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception

  public void write(io.netty.channel.ChannelHandlerContext, java.lang.Object, io.netty.channel.ChannelPromise);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
         0: .line 1
            aload 0
            aload 1
            aload 2
            aload 3
            invokespecial io.micronaut.http.netty.stream.HttpStreamsHandler.write:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception

  protected io.netty.handler.codec.http.HttpMessage createEmptyMessage(io.netty.handler.codec.http.HttpMessage);
    descriptor: (Lio/netty/handler/codec/http/HttpMessage;)Lio/netty/handler/codec/http/HttpMessage;
    flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast io.netty.handler.codec.http.HttpRequest
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.createEmptyMessage:(Lio/netty/handler/codec/http/HttpRequest;)Lio/netty/handler/codec/http/HttpRequest;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  protected boolean hasBody(io.netty.handler.codec.http.HttpMessage);
    descriptor: (Lio/netty/handler/codec/http/HttpMessage;)Z
    flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast io.netty.handler.codec.http.HttpRequest
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.hasBody:(Lio/netty/handler/codec/http/HttpRequest;)Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  protected io.netty.handler.codec.http.HttpMessage createStreamedMessage(io.netty.handler.codec.http.HttpMessage, org.reactivestreams.Publisher);
    descriptor: (Lio/netty/handler/codec/http/HttpMessage;Lorg/reactivestreams/Publisher;)Lio/netty/handler/codec/http/HttpMessage;
    flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            checkcast io.netty.handler.codec.http.HttpRequest
            aload 2
            invokevirtual io.micronaut.http.netty.stream.HttpStreamsServerHandler.createStreamedMessage:(Lio/netty/handler/codec/http/HttpRequest;Lorg/reactivestreams/Publisher;)Lio/netty/handler/codec/http/HttpRequest;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: Lio/micronaut/http/netty/stream/HttpStreamsHandler<Lio/netty/handler/codec/http/HttpRequest;Lio/netty/handler/codec/http/HttpResponse;>;
SourceFile: "HttpStreamsServerHandler.java"
InnerClasses:
  Outgoing = io.micronaut.http.netty.stream.HttpStreamsHandler$Outgoing of io.micronaut.http.netty.stream.HttpStreamsHandler
    RuntimeVisibleAnnotations: 
      io.micronaut.core.annotation.Internal()