public class io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder extends io.netty.channel.ChannelInboundHandlerAdapter
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder
  super_class: io.netty.channel.ChannelInboundHandlerAdapter
{
  private final java.util.Deque<io.reactiverse.pgclient.impl.CommandBase<?>> inflight;
    descriptor: Ljava/util/Deque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Deque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;

  private final io.netty.buffer.ByteBufAllocator alloc;
    descriptor: Lio/netty/buffer/ByteBufAllocator;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.vertx.core.Handler<? super io.reactiverse.pgclient.impl.CommandResponse<?>> commandResponseHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<-Lio/reactiverse/pgclient/impl/CommandResponse<*>;>;

  private io.vertx.core.Handler<io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse> noticeHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;>;

  private io.netty.buffer.ByteBuf in;
    descriptor: Lio/netty/buffer/ByteBuf;
    flags: (0x0002) ACC_PRIVATE

  private static final byte I;
    descriptor: B
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 73

  private static final byte T;
    descriptor: B
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 84

  private io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor processor;
    descriptor: Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder$CommandCompleteProcessor;
    flags: (0x0002) ACC_PRIVATE

  public void <init>(java.util.Deque<io.reactiverse.pgclient.impl.CommandBase<?>>, io.netty.buffer.ByteBufAllocator);
    descriptor: (Ljava/util/Deque;Lio/netty/buffer/ByteBufAllocator;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // java.util.Deque inflight
        start local 2 // io.netty.buffer.ByteBufAllocator alloc
         0: .line 57
            aload 0 /* this */
            invokespecial io.netty.channel.ChannelInboundHandlerAdapter.<init>:()V
         1: .line 373
            aload 0 /* this */
            new io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor
            dup
            invokespecial io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor.<init>:()V
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.processor:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder$CommandCompleteProcessor;
         2: .line 58
            aload 0 /* this */
            aload 1 /* inflight */
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
         3: .line 59
            aload 0 /* this */
            aload 2 /* alloc */
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.alloc:Lio/netty/buffer/ByteBufAllocator;
         4: .line 60
            return
        end local 2 // io.netty.buffer.ByteBufAllocator alloc
        end local 1 // java.util.Deque inflight
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    5     1  inflight  Ljava/util/Deque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;
            0    5     2     alloc  Lio/netty/buffer/ByteBufAllocator;
    Signature: (Ljava/util/Deque<Lio/reactiverse/pgclient/impl/CommandBase<*>;>;Lio/netty/buffer/ByteBufAllocator;)V
    MethodParameters:
          Name  Flags
      inflight  
      alloc     

  public void run(io.reactiverse.pgclient.impl.CommandBase<?>);
    descriptor: (Lio/reactiverse/pgclient/impl/CommandBase;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.reactiverse.pgclient.impl.CommandBase cmd
         0: .line 63
            aload 1 /* cmd */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.commandResponseHandler:Lio/vertx/core/Handler;
            putfield io.reactiverse.pgclient.impl.CommandBase.completionHandler:Lio/vertx/core/Handler;
         1: .line 64
            aload 1 /* cmd */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.noticeHandler:Lio/vertx/core/Handler;
            putfield io.reactiverse.pgclient.impl.CommandBase.noticeHandler:Lio/vertx/core/Handler;
         2: .line 65
            return
        end local 1 // io.reactiverse.pgclient.impl.CommandBase cmd
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    3     1   cmd  Lio/reactiverse/pgclient/impl/CommandBase<*>;
    Signature: (Lio/reactiverse/pgclient/impl/CommandBase<*>;)V
    MethodParameters:
      Name  Flags
      cmd   

  public void handlerAdded(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 69
            aload 0 /* this */
            aload 1 /* ctx */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic handle(Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/netty/channel/ChannelHandlerContext.fireChannelRead(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext; (9 itf)
                  (Lio/reactiverse/pgclient/impl/CommandResponse;)V
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.commandResponseHandler:Lio/vertx/core/Handler;
         1: .line 70
            aload 0 /* this */
            aload 1 /* ctx */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic handle(Lio/netty/channel/ChannelHandlerContext;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/netty/channel/ChannelHandlerContext.fireChannelRead(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext; (9 itf)
                  (Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;)V
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.noticeHandler:Lio/vertx/core/Handler;
         2: .line 71
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    3     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    Exceptions:
      throws java.lang.Exception
    MethodParameters:
      Name  Flags
      ctx   

  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=4, locals=11, args_size=3
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // java.lang.Object msg
         0: .line 75
            aload 2 /* msg */
            checkcast io.netty.buffer.ByteBuf
            astore 3 /* buff */
        start local 3 // io.netty.buffer.ByteBuf buff
         1: .line 76
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            ifnonnull 4
         2: .line 77
            aload 0 /* this */
            aload 3 /* buff */
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
         3: .line 78
            goto 11
         4: .line 80
      StackMap locals: io.netty.buffer.ByteBuf
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            instanceof io.netty.buffer.CompositeByteBuf
            ifeq 7
         5: .line 81
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            checkcast io.netty.buffer.CompositeByteBuf
            astore 4 /* composite */
        start local 4 // io.netty.buffer.CompositeByteBuf composite
         6: .line 82
            goto 10
        end local 4 // io.netty.buffer.CompositeByteBuf composite
         7: .line 83
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.alloc:Lio/netty/buffer/ByteBufAllocator;
            invokeinterface io.netty.buffer.ByteBufAllocator.compositeBuffer:()Lio/netty/buffer/CompositeByteBuf;
            astore 4 /* composite */
        start local 4 // io.netty.buffer.CompositeByteBuf composite
         8: .line 84
            aload 4 /* composite */
            iconst_1
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.CompositeByteBuf.addComponent:(ZLio/netty/buffer/ByteBuf;)Lio/netty/buffer/CompositeByteBuf;
            pop
         9: .line 85
            aload 0 /* this */
            aload 4 /* composite */
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
        10: .line 87
      StackMap locals: io.netty.buffer.CompositeByteBuf
      StackMap stack:
            aload 4 /* composite */
            iconst_1
            aload 3 /* buff */
            invokevirtual io.netty.buffer.CompositeByteBuf.addComponent:(ZLio/netty/buffer/ByteBuf;)Lio/netty/buffer/CompositeByteBuf;
            pop
        end local 4 // io.netty.buffer.CompositeByteBuf composite
        11: .line 90
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
            istore 4 /* available */
        start local 4 // int available
        12: .line 91
            iload 4 /* available */
            iconst_5
            if_icmpge 14
        13: .line 92
            goto 38
        14: .line 94
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
            istore 5 /* beginIdx */
        start local 5 // int beginIdx
        15: .line 95
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            iload 5 /* beginIdx */
            iconst_1
            iadd
            invokevirtual io.netty.buffer.ByteBuf.getInt:(I)I
            istore 6 /* length */
        start local 6 // int length
        16: .line 96
            iload 6 /* length */
            iconst_1
            iadd
            iload 4 /* available */
            if_icmple 18
        17: .line 97
            goto 38
        18: .line 99
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            iload 5 /* beginIdx */
            invokevirtual io.netty.buffer.ByteBuf.getByte:(I)B
            istore 7 /* id */
        start local 7 // byte id
        19: .line 100
            iload 5 /* beginIdx */
            iload 6 /* length */
            iadd
            iconst_1
            iadd
            istore 8 /* endIdx */
        start local 8 // int endIdx
        20: .line 101
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 9 /* writerIndex */
        start local 9 // int writerIndex
        21: .line 103
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            iload 5 /* beginIdx */
            iconst_5
            iadd
            iload 8 /* endIdx */
            invokevirtual io.netty.buffer.ByteBuf.setIndex:(II)Lio/netty/buffer/ByteBuf;
            pop
        22: .line 104
            iload 7 /* id */
            lookupswitch { // 4
                   50: 29
                   67: 27
                   68: 25
                   90: 23
              default: 31
          }
        23: .line 106
      StackMap locals: int int int
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeReadyForQuery:(Lio/netty/buffer/ByteBuf;)V
        24: .line 107
            goto 36
        25: .line 110
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeDataRow:(Lio/netty/buffer/ByteBuf;)V
        26: .line 111
            goto 36
        27: .line 114
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeCommandComplete:(Lio/netty/buffer/ByteBuf;)V
        28: .line 115
            goto 36
        29: .line 118
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeBindComplete:()V
        30: .line 119
            goto 36
        31: .line 122
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            iload 7 /* id */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeMessage:(Lio/netty/channel/ChannelHandlerContext;BLio/netty/buffer/ByteBuf;)V
        32: .line 125
            goto 36
      StackMap locals:
      StackMap stack: java.lang.Throwable
        33: astore 10
        34: .line 126
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            iload 8 /* endIdx */
            iload 9 /* writerIndex */
            invokevirtual io.netty.buffer.ByteBuf.setIndex:(II)Lio/netty/buffer/ByteBuf;
            pop
        35: .line 127
            aload 10
            athrow
        36: .line 126
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            iload 8 /* endIdx */
            iload 9 /* writerIndex */
            invokevirtual io.netty.buffer.ByteBuf.setIndex:(II)Lio/netty/buffer/ByteBuf;
            pop
        end local 9 // int writerIndex
        end local 8 // int endIdx
        end local 7 // byte id
        end local 6 // int length
        end local 5 // int beginIdx
        end local 4 // int available
        37: .line 89
            goto 11
        38: .line 129
      StackMap locals: io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder io.netty.channel.ChannelHandlerContext java.lang.Object io.netty.buffer.ByteBuf
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            ifnull 41
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.isReadable:()Z
            ifne 41
        39: .line 130
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.release:()Z
            pop
        40: .line 131
            aload 0 /* this */
            aconst_null
            putfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.in:Lio/netty/buffer/ByteBuf;
        41: .line 133
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.netty.buffer.ByteBuf buff
        end local 2 // java.lang.Object msg
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   42     0         this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0   42     1          ctx  Lio/netty/channel/ChannelHandlerContext;
            0   42     2          msg  Ljava/lang/Object;
            1   42     3         buff  Lio/netty/buffer/ByteBuf;
            6    7     4    composite  Lio/netty/buffer/CompositeByteBuf;
            8   11     4    composite  Lio/netty/buffer/CompositeByteBuf;
           12   37     4    available  I
           15   37     5     beginIdx  I
           16   37     6       length  I
           19   37     7           id  B
           20   37     8       endIdx  I
           21   37     9  writerIndex  I
      Exception table:
        from    to  target  type
          21    33      33  any
    MethodParameters:
      Name  Flags
      ctx   
      msg   

  private void decodeMessage(io.netty.channel.ChannelHandlerContext, byte, io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;BLio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // byte id
        start local 3 // io.netty.buffer.ByteBuf in
         0: .line 136
            iload 2 /* id */
            lookupswitch { // 13
                   49: 11
                   51: 13
                   65: 25
                   69: 3
                   73: 9
                   75: 23
                   78: 5
                   82: 7
                   83: 21
                   84: 1
                  110: 15
                  115: 17
                  116: 19
              default: 27
          }
         1: .line 138
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeRowDescription:(Lio/netty/buffer/ByteBuf;)V
         2: .line 139
            goto 28
         3: .line 142
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeError:(Lio/netty/buffer/ByteBuf;)V
         4: .line 143
            goto 28
         5: .line 146
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeNotice:(Lio/netty/buffer/ByteBuf;)V
         6: .line 147
            goto 28
         7: .line 150
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeAuthentication:(Lio/netty/buffer/ByteBuf;)V
         8: .line 151
            goto 28
         9: .line 154
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeEmptyQueryResponse:()V
        10: .line 155
            goto 28
        11: .line 158
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeParseComplete:()V
        12: .line 159
            goto 28
        13: .line 162
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeCloseComplete:()V
        14: .line 163
            goto 28
        15: .line 166
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeNoData:()V
        16: .line 167
            goto 28
        17: .line 170
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodePortalSuspended:()V
        18: .line 171
            goto 28
        19: .line 174
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeParameterDescription:(Lio/netty/buffer/ByteBuf;)V
        20: .line 175
            goto 28
        21: .line 178
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeParameterStatus:(Lio/netty/buffer/ByteBuf;)V
        22: .line 179
            goto 28
        23: .line 182
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeBackendKeyData:(Lio/netty/buffer/ByteBuf;)V
        24: .line 183
            goto 28
        25: .line 186
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* ctx */
            aload 3 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeNotificationResponse:(Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;)V
        26: .line 187
            goto 28
        27: .line 190
      StackMap locals:
      StackMap stack:
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        28: .line 193
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.netty.buffer.ByteBuf in
        end local 2 // byte id
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   29     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0   29     1   ctx  Lio/netty/channel/ChannelHandlerContext;
            0   29     2    id  B
            0   29     3    in  Lio/netty/buffer/ByteBuf;
    MethodParameters:
      Name  Flags
      ctx   
      id    
      in    

  private void decodePortalSuspended();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
         0: .line 196
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handlePortalSuspended:()V
         1: .line 197
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;

  private void decodeCommandComplete(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 200
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.processor:Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder$CommandCompleteProcessor;
            aload 1 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor.parse:(Lio/netty/buffer/ByteBuf;)I
            istore 2 /* updated */
        start local 2 // int updated
         1: .line 201
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            iload 2 /* updated */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleCommandComplete:(I)V
         2: .line 202
            return
        end local 2 // int updated
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    3     1       in  Lio/netty/buffer/ByteBuf;
            1    3     2  updated  I
    MethodParameters:
      Name  Flags
      in    

  private void decodeDataRow(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 205
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.QueryCommandBase
            astore 2 /* cmd */
        start local 2 // io.reactiverse.pgclient.impl.QueryCommandBase cmd
         1: .line 206
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
            istore 3 /* len */
        start local 3 // int len
         2: .line 207
            aload 2 /* cmd */
            getfield io.reactiverse.pgclient.impl.QueryCommandBase.decoder:Lio/reactiverse/pgclient/impl/RowResultDecoder;
            iload 3 /* len */
            aload 1 /* in */
            invokevirtual io.reactiverse.pgclient.impl.RowResultDecoder.decodeRow:(ILio/netty/buffer/ByteBuf;)V
         3: .line 208
            return
        end local 3 // int len
        end local 2 // io.reactiverse.pgclient.impl.QueryCommandBase cmd
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    4     1    in  Lio/netty/buffer/ByteBuf;
            1    4     2   cmd  Lio/reactiverse/pgclient/impl/QueryCommandBase<*>;
            2    4     3   len  I
    MethodParameters:
      Name  Flags
      in    

  private void decodeRowDescription(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=9, locals=12, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 211
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
            anewarray io.reactiverse.pgclient.impl.codec.ColumnDesc
            astore 2 /* columns */
        start local 2 // io.reactiverse.pgclient.impl.codec.ColumnDesc[] columns
         1: .line 212
            iconst_0
            istore 3 /* c */
        start local 3 // int c
         2: goto 21
         3: .line 213
      StackMap locals: io.reactiverse.pgclient.impl.codec.ColumnDesc[] int
      StackMap stack:
            aload 1 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            astore 4 /* fieldName */
        start local 4 // java.lang.String fieldName
         4: .line 214
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            istore 5 /* tableOID */
        start local 5 // int tableOID
         5: .line 215
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readShort:()S
            istore 6 /* columnAttributeNumber */
        start local 6 // short columnAttributeNumber
         6: .line 216
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            istore 7 /* typeOID */
        start local 7 // int typeOID
         7: .line 217
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readShort:()S
            istore 8 /* typeSize */
        start local 8 // short typeSize
         8: .line 218
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            istore 9 /* typeModifier */
        start local 9 // int typeModifier
         9: .line 219
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
            istore 10 /* textOrBinary */
        start local 10 // int textOrBinary
        10: .line 220
            new io.reactiverse.pgclient.impl.codec.ColumnDesc
            dup
        11: .line 221
            aload 4 /* fieldName */
        12: .line 222
            iload 5 /* tableOID */
        13: .line 223
            iload 6 /* columnAttributeNumber */
        14: .line 224
            iload 7 /* typeOID */
            invokestatic io.reactiverse.pgclient.impl.codec.DataType.valueOf:(I)Lio/reactiverse/pgclient/impl/codec/DataType;
        15: .line 225
            iload 8 /* typeSize */
        16: .line 226
            iload 9 /* typeModifier */
        17: .line 227
            iload 10 /* textOrBinary */
            invokestatic io.reactiverse.pgclient.impl.codec.DataFormat.valueOf:(I)Lio/reactiverse/pgclient/impl/codec/DataFormat;
        18: .line 220
            invokespecial io.reactiverse.pgclient.impl.codec.ColumnDesc.<init>:(Ljava/lang/String;ISLio/reactiverse/pgclient/impl/codec/DataType;SILio/reactiverse/pgclient/impl/codec/DataFormat;)V
            astore 11 /* column */
        start local 11 // io.reactiverse.pgclient.impl.codec.ColumnDesc column
        19: .line 229
            aload 2 /* columns */
            iload 3 /* c */
            aload 11 /* column */
            aastore
        end local 11 // io.reactiverse.pgclient.impl.codec.ColumnDesc column
        end local 10 // int textOrBinary
        end local 9 // int typeModifier
        end local 8 // short typeSize
        end local 7 // int typeOID
        end local 6 // short columnAttributeNumber
        end local 5 // int tableOID
        end local 4 // java.lang.String fieldName
        20: .line 212
            iinc 3 /* c */ 1
      StackMap locals:
      StackMap stack:
        21: iload 3 /* c */
            aload 2 /* columns */
            arraylength
            if_icmplt 3
        end local 3 // int c
        22: .line 231
            new io.reactiverse.pgclient.impl.codec.decoder.RowDescription
            dup
            aload 2 /* columns */
            invokespecial io.reactiverse.pgclient.impl.codec.decoder.RowDescription.<init>:([Lio/reactiverse/pgclient/impl/codec/ColumnDesc;)V
            astore 3 /* rowDesc */
        start local 3 // io.reactiverse.pgclient.impl.codec.decoder.RowDescription rowDesc
        23: .line 232
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            aload 3 /* rowDesc */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleRowDescription:(Lio/reactiverse/pgclient/impl/codec/decoder/RowDescription;)V
        24: .line 233
            return
        end local 3 // io.reactiverse.pgclient.impl.codec.decoder.RowDescription rowDesc
        end local 2 // io.reactiverse.pgclient.impl.codec.ColumnDesc[] columns
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   25     0                   this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0   25     1                     in  Lio/netty/buffer/ByteBuf;
            1   25     2                columns  [Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
            2   22     3                      c  I
            4   20     4              fieldName  Ljava/lang/String;
            5   20     5               tableOID  I
            6   20     6  columnAttributeNumber  S
            7   20     7                typeOID  I
            8   20     8               typeSize  S
            9   20     9           typeModifier  I
           10   20    10           textOrBinary  I
           19   20    11                 column  Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
           23   25     3                rowDesc  Lio/reactiverse/pgclient/impl/codec/decoder/RowDescription;
    MethodParameters:
      Name  Flags
      in    

  private void decodeReadyForQuery(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 238
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readByte:()B
            istore 2 /* id */
        start local 2 // byte id
         1: .line 240
            iload 2 /* id */
            bipush 73
            if_icmpne 4
         2: .line 241
            getstatic io.reactiverse.pgclient.impl.codec.TxStatus.IDLE:Lio/reactiverse/pgclient/impl/codec/TxStatus;
            astore 3 /* txStatus */
        start local 3 // io.reactiverse.pgclient.impl.codec.TxStatus txStatus
         3: .line 242
            goto 8
        end local 3 // io.reactiverse.pgclient.impl.codec.TxStatus txStatus
      StackMap locals: int
      StackMap stack:
         4: iload 2 /* id */
            bipush 84
            if_icmpne 7
         5: .line 243
            getstatic io.reactiverse.pgclient.impl.codec.TxStatus.ACTIVE:Lio/reactiverse/pgclient/impl/codec/TxStatus;
            astore 3 /* txStatus */
        start local 3 // io.reactiverse.pgclient.impl.codec.TxStatus txStatus
         6: .line 244
            goto 8
        end local 3 // io.reactiverse.pgclient.impl.codec.TxStatus txStatus
         7: .line 245
      StackMap locals:
      StackMap stack:
            getstatic io.reactiverse.pgclient.impl.codec.TxStatus.FAILED:Lio/reactiverse/pgclient/impl/codec/TxStatus;
            astore 3 /* txStatus */
        start local 3 // io.reactiverse.pgclient.impl.codec.TxStatus txStatus
         8: .line 247
      StackMap locals: io.reactiverse.pgclient.impl.codec.TxStatus
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            aload 3 /* txStatus */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleReadyForQuery:(Lio/reactiverse/pgclient/impl/codec/TxStatus;)V
         9: .line 248
            return
        end local 3 // io.reactiverse.pgclient.impl.codec.TxStatus txStatus
        end local 2 // byte id
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0   10     1        in  Lio/netty/buffer/ByteBuf;
            1   10     2        id  B
            3    4     3  txStatus  Lio/reactiverse/pgclient/impl/codec/TxStatus;
            6    7     3  txStatus  Lio/reactiverse/pgclient/impl/codec/TxStatus;
            8   10     3  txStatus  Lio/reactiverse/pgclient/impl/codec/TxStatus;
    MethodParameters:
      Name  Flags
      in    

  private void decodeError(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 251
            new io.reactiverse.pgclient.impl.codec.decoder.ErrorResponse
            dup
            invokespecial io.reactiverse.pgclient.impl.codec.decoder.ErrorResponse.<init>:()V
            astore 2 /* response */
        start local 2 // io.reactiverse.pgclient.impl.codec.decoder.ErrorResponse response
         1: .line 252
            aload 0 /* this */
            aload 2 /* response */
            aload 1 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeErrorOrNotice:(Lio/reactiverse/pgclient/impl/codec/decoder/Response;Lio/netty/buffer/ByteBuf;)V
         2: .line 253
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            aload 2 /* response */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleErrorResponse:(Lio/reactiverse/pgclient/impl/codec/decoder/ErrorResponse;)V
         3: .line 254
            return
        end local 2 // io.reactiverse.pgclient.impl.codec.decoder.ErrorResponse response
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    4     1        in  Lio/netty/buffer/ByteBuf;
            1    4     2  response  Lio/reactiverse/pgclient/impl/codec/decoder/ErrorResponse;
    MethodParameters:
      Name  Flags
      in    

  private void decodeNotice(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 257
            new io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse
            dup
            invokespecial io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse.<init>:()V
            astore 2 /* response */
        start local 2 // io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse response
         1: .line 258
            aload 0 /* this */
            aload 2 /* response */
            aload 1 /* in */
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.decodeErrorOrNotice:(Lio/reactiverse/pgclient/impl/codec/decoder/Response;Lio/netty/buffer/ByteBuf;)V
         2: .line 259
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            aload 2 /* response */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleNoticeResponse:(Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;)V
         3: .line 260
            return
        end local 2 // io.reactiverse.pgclient.impl.codec.decoder.NoticeResponse response
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    4     1        in  Lio/netty/buffer/ByteBuf;
            1    4     2  response  Lio/reactiverse/pgclient/impl/codec/decoder/NoticeResponse;
    MethodParameters:
      Name  Flags
      in    

  private void decodeErrorOrNotice(io.reactiverse.pgclient.impl.codec.decoder.Response, io.netty.buffer.ByteBuf);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/decoder/Response;Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.decoder.Response response
        start local 2 // io.netty.buffer.ByteBuf in
         0: .line 266
            goto 37
        start local 3 // byte type
         1: .line 268
      StackMap locals: int
      StackMap stack:
            iload 3 /* type */
            lookupswitch { // 17
                   67: 4
                   68: 8
                   70: 20
                   72: 10
                   76: 22
                   77: 6
                   80: 16
                   82: 24
                   83: 2
                   87: 18
                   99: 30
                  100: 32
                  110: 34
                  112: 12
                  113: 14
                  115: 26
                  116: 28
              default: 36
          }
         2: .line 271
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setSeverity:(Ljava/lang/String;)V
         3: .line 272
            goto 37
         4: .line 275
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setCode:(Ljava/lang/String;)V
         5: .line 276
            goto 37
         6: .line 279
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setMessage:(Ljava/lang/String;)V
         7: .line 280
            goto 37
         8: .line 283
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setDetail:(Ljava/lang/String;)V
         9: .line 284
            goto 37
        10: .line 287
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setHint:(Ljava/lang/String;)V
        11: .line 288
            goto 37
        12: .line 291
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setInternalPosition:(Ljava/lang/String;)V
        13: .line 292
            goto 37
        14: .line 295
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setInternalQuery:(Ljava/lang/String;)V
        15: .line 296
            goto 37
        16: .line 299
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setPosition:(Ljava/lang/String;)V
        17: .line 300
            goto 37
        18: .line 303
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setWhere:(Ljava/lang/String;)V
        19: .line 304
            goto 37
        20: .line 307
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setFile:(Ljava/lang/String;)V
        21: .line 308
            goto 37
        22: .line 311
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setLine:(Ljava/lang/String;)V
        23: .line 312
            goto 37
        24: .line 315
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setRoutine:(Ljava/lang/String;)V
        25: .line 316
            goto 37
        26: .line 319
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setSchema:(Ljava/lang/String;)V
        27: .line 320
            goto 37
        28: .line 323
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setTable:(Ljava/lang/String;)V
        29: .line 324
            goto 37
        30: .line 327
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setColumn:(Ljava/lang/String;)V
        31: .line 328
            goto 37
        32: .line 331
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setDataType:(Ljava/lang/String;)V
        33: .line 332
            goto 37
        34: .line 335
      StackMap locals:
      StackMap stack:
            aload 1 /* response */
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokevirtual io.reactiverse.pgclient.impl.codec.decoder.Response.setConstraint:(Ljava/lang/String;)V
        35: .line 336
            goto 37
        36: .line 339
      StackMap locals:
      StackMap stack:
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            pop
        end local 3 // byte type
        37: .line 266
      StackMap locals:
      StackMap stack:
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readByte:()B
            dup
            istore 3 /* type */
        start local 3 // byte type
        38: ifne 1
        39: .line 343
            return
        end local 3 // byte type
        end local 2 // io.netty.buffer.ByteBuf in
        end local 1 // io.reactiverse.pgclient.impl.codec.decoder.Response response
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   40     0      this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0   40     1  response  Lio/reactiverse/pgclient/impl/codec/decoder/Response;
            0   40     2        in  Lio/netty/buffer/ByteBuf;
            1   37     3      type  B
           38   40     3      type  B
    MethodParameters:
          Name  Flags
      response  
      in        

  private void decodeAuthentication(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 347
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            istore 2 /* type */
        start local 2 // int type
         1: .line 348
            iload 2 /* type */
            tableswitch { // 0 - 9
                    0: 2
                    1: 10
                    2: 10
                    3: 8
                    4: 10
                    5: 4
                    6: 10
                    7: 10
                    8: 10
                    9: 10
              default: 10
          }
         2: .line 350
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleAuthenticationOk:()V
         3: .line 352
            goto 11
         4: .line 354
      StackMap locals:
      StackMap stack:
            iconst_4
            newarray 8
            astore 3 /* salt */
        start local 3 // byte[] salt
         5: .line 355
            aload 1 /* in */
            aload 3 /* salt */
            invokevirtual io.netty.buffer.ByteBuf.readBytes:([B)Lio/netty/buffer/ByteBuf;
            pop
         6: .line 356
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            aload 3 /* salt */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleAuthenticationMD5Password:([B)V
        end local 3 // byte[] salt
         7: .line 358
            goto 11
         8: .line 360
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleAuthenticationClearTextPassword:()V
         9: .line 362
            goto 11
        10: .line 369
      StackMap locals:
      StackMap stack:
            new java.lang.UnsupportedOperationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Authentication type "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* type */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " is not supported in the client"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
            athrow
        11: .line 371
      StackMap locals:
      StackMap stack:
            return
        end local 2 // int type
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   12     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0   12     1    in  Lio/netty/buffer/ByteBuf;
            1   12     2  type  I
            5    7     3  salt  [B
    MethodParameters:
      Name  Flags
      in    

  private void decodeParseComplete();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
         0: .line 402
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleParseComplete:()V
         1: .line 403
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;

  private void decodeBindComplete();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
         0: .line 406
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleBindComplete:()V
         1: .line 407
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;

  private void decodeCloseComplete();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
         0: .line 410
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleCloseComplete:()V
         1: .line 411
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;

  private void decodeNoData();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
         0: .line 414
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleNoData:()V
         1: .line 415
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;

  private void decodeParameterDescription(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 418
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
            anewarray io.reactiverse.pgclient.impl.codec.DataType
            astore 2 /* paramDataTypes */
        start local 2 // io.reactiverse.pgclient.impl.codec.DataType[] paramDataTypes
         1: .line 419
            iconst_0
            istore 3 /* c */
        start local 3 // int c
         2: goto 5
         3: .line 420
      StackMap locals: io.reactiverse.pgclient.impl.codec.DataType[] int
      StackMap stack:
            aload 2 /* paramDataTypes */
            iload 3 /* c */
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            invokestatic io.reactiverse.pgclient.impl.codec.DataType.valueOf:(I)Lio/reactiverse/pgclient/impl/codec/DataType;
            aastore
         4: .line 419
            iinc 3 /* c */ 1
      StackMap locals:
      StackMap stack:
         5: iload 3 /* c */
            aload 2 /* paramDataTypes */
            arraylength
            if_icmplt 3
        end local 3 // int c
         6: .line 422
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            new io.reactiverse.pgclient.impl.codec.decoder.ParameterDescription
            dup
            aload 2 /* paramDataTypes */
            invokespecial io.reactiverse.pgclient.impl.codec.decoder.ParameterDescription.<init>:([Lio/reactiverse/pgclient/impl/codec/DataType;)V
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleParameterDescription:(Lio/reactiverse/pgclient/impl/codec/decoder/ParameterDescription;)V
         7: .line 423
            return
        end local 2 // io.reactiverse.pgclient.impl.codec.DataType[] paramDataTypes
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    8     0            this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    8     1              in  Lio/netty/buffer/ByteBuf;
            1    8     2  paramDataTypes  [Lio/reactiverse/pgclient/impl/codec/DataType;
            2    6     3               c  I
    MethodParameters:
      Name  Flags
      in    

  private void decodeParameterStatus(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 426
            aload 1 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            astore 2 /* key */
        start local 2 // java.lang.String key
         1: .line 427
            aload 1 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            astore 3 /* value */
        start local 3 // java.lang.String value
         2: .line 428
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            aload 2 /* key */
            aload 3 /* value */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleParameterStatus:(Ljava/lang/String;Ljava/lang/String;)V
         3: .line 429
            return
        end local 3 // java.lang.String value
        end local 2 // java.lang.String key
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    4     1     in  Lio/netty/buffer/ByteBuf;
            1    4     2    key  Ljava/lang/String;
            2    4     3  value  Ljava/lang/String;
    MethodParameters:
      Name  Flags
      in    

  private void decodeEmptyQueryResponse();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
         0: .line 432
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleEmptyQueryResponse:()V
         1: .line 433
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;

  private void decodeBackendKeyData(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.buffer.ByteBuf in
         0: .line 436
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            istore 2 /* processId */
        start local 2 // int processId
         1: .line 437
            aload 1 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            istore 3 /* secretKey */
        start local 3 // int secretKey
         2: .line 438
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder.inflight:Ljava/util/Deque;
            invokeinterface java.util.Deque.peek:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.impl.CommandBase
            iload 2 /* processId */
            iload 3 /* secretKey */
            invokevirtual io.reactiverse.pgclient.impl.CommandBase.handleBackendKeyData:(II)V
         3: .line 439
            return
        end local 3 // int secretKey
        end local 2 // int processId
        end local 1 // io.netty.buffer.ByteBuf in
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    4     1         in  Lio/netty/buffer/ByteBuf;
            1    4     2  processId  I
            2    4     3  secretKey  I
    MethodParameters:
      Name  Flags
      in    

  private void decodeNotificationResponse(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=3, args_size=3
        start local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.buffer.ByteBuf in
         0: .line 442
            aload 1 /* ctx */
            new io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse
            dup
            aload 2 /* in */
            invokevirtual io.netty.buffer.ByteBuf.readInt:()I
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            aload 2 /* in */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.readCStringUTF8:(Lio/netty/buffer/ByteBuf;)Ljava/lang/String;
            invokespecial io.reactiverse.pgclient.impl.codec.decoder.NotificationResponse.<init>:(ILjava/lang/String;Ljava/lang/String;)V
            invokeinterface io.netty.channel.ChannelHandlerContext.fireChannelRead:(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext;
            pop
         1: .line 443
            return
        end local 2 // io.netty.buffer.ByteBuf in
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/reactiverse/pgclient/impl/codec/decoder/MessageDecoder;
            0    2     1   ctx  Lio/netty/channel/ChannelHandlerContext;
            0    2     2    in  Lio/netty/buffer/ByteBuf;
    MethodParameters:
      Name  Flags
      ctx   
      in    
}
SourceFile: "MessageDecoder.java"
NestMembers:
  io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor
InnerClasses:
  CommandCompleteProcessor = io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder$CommandCompleteProcessor of io.reactiverse.pgclient.impl.codec.decoder.MessageDecoder
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles