https://github.com/reactiverse/reactive-pg-client: The reactive Postgres client (Eclipse)
  • Julien Viet
  • Emad Alblueshi 
public final class io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder
  super_class: java.lang.Object
{
  private static final byte PASSWORD_MESSAGE;
    descriptor: B
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 112

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

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

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

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

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

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

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

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

  private final io.netty.channel.ChannelHandlerContext ctx;
    descriptor: Lio/netty/channel/ChannelHandlerContext;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  public void <init>(io.netty.channel.ChannelHandlerContext);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
         0: .line 57
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 58
            aload 0 /* this */
            aload 1 /* ctx */
            putfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ctx:Lio/netty/channel/ChannelHandlerContext;
         2: .line 59
            return
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0    3     1   ctx  Lio/netty/channel/ChannelHandlerContext;
    MethodParameters:
      Name  Flags
      ctx   

  public void flush();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
         0: .line 62
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            ifnull 4
         1: .line 63
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            astore 1 /* buff */
        start local 1 // io.netty.buffer.ByteBuf buff
         2: .line 64
            aload 0 /* this */
            aconst_null
            putfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
         3: .line 65
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ctx:Lio/netty/channel/ChannelHandlerContext;
            aload 1 /* buff */
            invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
            pop
        end local 1 // io.netty.buffer.ByteBuf buff
         4: .line 67
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            2    4     1  buff  Lio/netty/buffer/ByteBuf;

  public void writeTerminate();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
         0: .line 74
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 75
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 88
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         2: .line 76
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_4
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 77
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;

  public void writeSync();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
         0: .line 93
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 94
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 83
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         2: .line 95
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_4
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 96
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;

  public void writeClosePortal(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // java.lang.String portal
         0: .line 108
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 109
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 2 /* pos */
        start local 2 // int pos
         2: .line 110
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 67
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 111
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 112
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 80
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         5: .line 113
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* portal */
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
         6: .line 114
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 2 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
         7: .line 115
            return
        end local 2 // int pos
        end local 1 // java.lang.String portal
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0    8     1  portal  Ljava/lang/String;
            2    8     2     pos  I
    MethodParameters:
        Name  Flags
      portal  

  public void writeStartupMessage(io.reactiverse.pgclient.impl.codec.encoder.StartupMessage);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/encoder/StartupMessage;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.encoder.StartupMessage msg
         0: .line 118
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 120
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 2 /* pos */
        start local 2 // int pos
         2: .line 122
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 124
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_3
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 125
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
         5: .line 127
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_USER:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
         6: .line 128
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* msg */
            getfield io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.username:Ljava/lang/String;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
         7: .line 129
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_DATABASE:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
         8: .line 130
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* msg */
            getfield io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.database:Ljava/lang/String;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
         9: .line 131
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_APPLICATION_NAME:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        10: .line 132
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_VERTX_PG_CLIENT:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        11: .line 133
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_CLIENT_ENCODING:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        12: .line 134
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_UTF8:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        13: .line 135
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_DATE_STYLE:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        14: .line 136
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_ISO:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        15: .line 137
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_INTERVAL_STYLE:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        16: .line 138
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_INTERVAL_STYLE_TYPE:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        17: .line 139
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_EXTRA_FLOAT_DIGITS:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        18: .line 140
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            getstatic io.reactiverse.pgclient.impl.codec.encoder.StartupMessage.BUFF_2:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCString:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBuf;)V
        19: .line 142
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
        20: .line 143
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* pos */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 2 /* pos */
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
        21: .line 144
            return
        end local 2 // int pos
        end local 1 // io.reactiverse.pgclient.impl.codec.encoder.StartupMessage msg
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   22     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0   22     1   msg  Lio/reactiverse/pgclient/impl/codec/encoder/StartupMessage;
            2   22     2   pos  I
    MethodParameters:
      Name  Flags
      msg   

  public void writePasswordMessage(io.reactiverse.pgclient.impl.codec.encoder.PasswordMessage);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/encoder/PasswordMessage;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.encoder.PasswordMessage msg
         0: .line 147
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 148
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 2 /* pos */
        start local 2 // int pos
         2: .line 149
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 112
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 150
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 151
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* msg */
            getfield io.reactiverse.pgclient.impl.codec.encoder.PasswordMessage.hash:Ljava/lang/String;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
         5: .line 152
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 2 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
         6: .line 153
            return
        end local 2 // int pos
        end local 1 // io.reactiverse.pgclient.impl.codec.encoder.PasswordMessage msg
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0    7     1   msg  Lio/reactiverse/pgclient/impl/codec/encoder/PasswordMessage;
            2    7     2   pos  I
    MethodParameters:
      Name  Flags
      msg   

  public void writeQuery(io.reactiverse.pgclient.impl.codec.encoder.Query);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/encoder/Query;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.encoder.Query query
         0: .line 164
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 165
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 2 /* pos */
        start local 2 // int pos
         2: .line 166
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 81
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 167
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 168
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* query */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Query.sql:Ljava/lang/String;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
         5: .line 169
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 2 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
         6: .line 170
            return
        end local 2 // int pos
        end local 1 // io.reactiverse.pgclient.impl.codec.encoder.Query query
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    7     0   this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0    7     1  query  Lio/reactiverse/pgclient/impl/codec/encoder/Query;
            2    7     2    pos  I
    MethodParameters:
       Name  Flags
      query  

  public void writeDescribe(io.reactiverse.pgclient.impl.codec.encoder.Describe);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/encoder/Describe;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.encoder.Describe describe
         0: .line 191
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 192
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 2 /* pos */
        start local 2 // int pos
         2: .line 193
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 68
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 194
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 195
            aload 1 /* describe */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Describe.statement:J
            lconst_0
            lcmp
            ifeq 8
         5: .line 196
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 83
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         6: .line 197
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* describe */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Describe.statement:J
            invokevirtual io.netty.buffer.ByteBuf.writeLong:(J)Lio/netty/buffer/ByteBuf;
            pop
         7: .line 198
            goto 14
      StackMap locals: int
      StackMap stack:
         8: aload 1 /* describe */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Describe.portal:Ljava/lang/String;
            ifnull 12
         9: .line 199
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 80
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
        10: .line 200
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* describe */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Describe.portal:Ljava/lang/String;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
        11: .line 201
            goto 14
        12: .line 202
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 83
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
        13: .line 203
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            ldc ""
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
        14: .line 205
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 2 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
        15: .line 206
            return
        end local 2 // int pos
        end local 1 // io.reactiverse.pgclient.impl.codec.encoder.Describe describe
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   16     0      this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0   16     1  describe  Lio/reactiverse/pgclient/impl/codec/encoder/Describe;
            2   16     2       pos  I
    MethodParameters:
          Name  Flags
      describe  

  public void writeParse(io.reactiverse.pgclient.impl.codec.encoder.Parse);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/encoder/Parse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.encoder.Parse parse
         0: .line 215
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 216
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 2 /* pos */
        start local 2 // int pos
         2: .line 217
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 80
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 218
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 219
            aload 1 /* parse */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Parse.statement:J
            lconst_0
            lcmp
            ifne 7
         5: .line 220
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         6: .line 221
            goto 8
         7: .line 222
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* parse */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Parse.statement:J
            invokevirtual io.netty.buffer.ByteBuf.writeLong:(J)Lio/netty/buffer/ByteBuf;
            pop
         8: .line 224
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* parse */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Parse.query:Ljava/lang/String;
            invokestatic io.reactiverse.pgclient.impl.codec.util.Util.writeCStringUTF8:(Lio/netty/buffer/ByteBuf;Ljava/lang/String;)V
         9: .line 227
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        10: .line 235
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 2 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
        11: .line 236
            return
        end local 2 // int pos
        end local 1 // io.reactiverse.pgclient.impl.codec.encoder.Parse parse
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   12     0   this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0   12     1  parse  Lio/reactiverse/pgclient/impl/codec/encoder/Parse;
            2   12     2    pos  I
    MethodParameters:
       Name  Flags
      parse  

  public void writeExecute(java.lang.String, int);
    descriptor: (Ljava/lang/String;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // java.lang.String portal
        start local 2 // int rowCount
         0: .line 257
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 258
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 3 /* pos */
        start local 3 // int pos
         2: .line 259
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 69
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 260
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 261
            aload 1 /* portal */
            ifnull 6
         5: .line 262
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* portal */
            getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
            invokevirtual io.netty.buffer.ByteBuf.writeCharSequence:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)I
            pop
         6: .line 264
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         7: .line 265
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 2 /* rowCount */
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         8: .line 266
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 3 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 3 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
         9: .line 267
            return
        end local 3 // int pos
        end local 2 // int rowCount
        end local 1 // java.lang.String portal
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0   10     1    portal  Ljava/lang/String;
            0   10     2  rowCount  I
            2   10     3       pos  I
    MethodParameters:
          Name  Flags
      portal    
      rowCount  

  public void writeBind(io.reactiverse.pgclient.impl.codec.encoder.Bind, java.lang.String, java.util.List<java.lang.Object>);
    descriptor: (Lio/reactiverse/pgclient/impl/codec/encoder/Bind;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=10, args_size=4
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
        start local 1 // io.reactiverse.pgclient.impl.codec.encoder.Bind bind
        start local 2 // java.lang.String portal
        start local 3 // java.util.List paramValues
         0: .line 278
            aload 0 /* this */
            invokevirtual io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ensureBuffer:()V
         1: .line 279
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 4 /* pos */
        start local 4 // int pos
         2: .line 280
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            bipush 66
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 281
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 282
            aload 2 /* portal */
            ifnull 6
         5: .line 283
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 2 /* portal */
            getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
            invokevirtual io.netty.buffer.ByteBuf.writeCharSequence:(Ljava/lang/CharSequence;Ljava/nio/charset/Charset;)I
            pop
         6: .line 285
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         7: .line 286
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.statement:J
            lconst_0
            lcmp
            ifne 10
         8: .line 287
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeByte:(I)Lio/netty/buffer/ByteBuf;
            pop
         9: .line 288
            goto 11
        10: .line 289
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.statement:J
            invokevirtual io.netty.buffer.ByteBuf.writeLong:(J)Lio/netty/buffer/ByteBuf;
            pop
        11: .line 291
      StackMap locals:
      StackMap stack:
            aload 3 /* paramValues */
            invokeinterface java.util.List.size:()I
            istore 5 /* paramLen */
        start local 5 // int paramLen
        12: .line 292
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 5 /* paramLen */
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        13: .line 294
            iconst_0
            istore 6 /* c */
        start local 6 // int c
        14: goto 19
        15: .line 296
      StackMap locals: int int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.paramTypes:[Lio/reactiverse/pgclient/impl/codec/DataType;
            iload 6 /* c */
            aaload
            getfield io.reactiverse.pgclient.impl.codec.DataType.supportsBinary:Z
            ifeq 16
            iconst_1
            goto 17
      StackMap locals:
      StackMap stack: io.netty.buffer.ByteBuf
        16: iconst_0
      StackMap locals: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder io.reactiverse.pgclient.impl.codec.encoder.Bind java.lang.String java.util.List int int int
      StackMap stack: io.netty.buffer.ByteBuf int
        17: invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        18: .line 294
            iinc 6 /* c */ 1
      StackMap locals:
      StackMap stack:
        19: iload 6 /* c */
            iload 5 /* paramLen */
            if_icmplt 15
        end local 6 // int c
        20: .line 298
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 5 /* paramLen */
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        21: .line 299
            iconst_0
            istore 6 /* c */
        start local 6 // int c
        22: goto 36
        23: .line 300
      StackMap locals:
      StackMap stack:
            aload 3 /* paramValues */
            iload 6 /* c */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            astore 7 /* param */
        start local 7 // java.lang.Object param
        24: .line 301
            aload 7 /* param */
            ifnonnull 27
        25: .line 303
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_m1
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
        26: .line 304
            goto 35
        27: .line 305
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.paramTypes:[Lio/reactiverse/pgclient/impl/codec/DataType;
            iload 6 /* c */
            aaload
            astore 8 /* dataType */
        start local 8 // io.reactiverse.pgclient.impl.codec.DataType dataType
        28: .line 306
            aload 8 /* dataType */
            getfield io.reactiverse.pgclient.impl.codec.DataType.supportsBinary:Z
            ifeq 34
        29: .line 307
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            istore 9 /* idx */
        start local 9 // int idx
        30: .line 308
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_0
            invokevirtual io.netty.buffer.ByteBuf.writeInt:(I)Lio/netty/buffer/ByteBuf;
            pop
        31: .line 309
            aload 8 /* dataType */
            aload 7 /* param */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.DataTypeCodec.encodeBinary:(Lio/reactiverse/pgclient/impl/codec/DataType;Ljava/lang/Object;Lio/netty/buffer/ByteBuf;)V
        32: .line 310
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 9 /* idx */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 9 /* idx */
            isub
            iconst_4
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
        end local 9 // int idx
        33: .line 311
            goto 35
        34: .line 312
      StackMap locals: io.reactiverse.pgclient.impl.codec.DataType
      StackMap stack:
            aload 8 /* dataType */
            aload 7 /* param */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokestatic io.reactiverse.pgclient.impl.codec.DataTypeCodec.encodeText:(Lio/reactiverse/pgclient/impl/codec/DataType;Ljava/lang/Object;Lio/netty/buffer/ByteBuf;)V
        end local 8 // io.reactiverse.pgclient.impl.codec.DataType dataType
        end local 7 // java.lang.Object param
        35: .line 299
      StackMap locals:
      StackMap stack:
            iinc 6 /* c */ 1
      StackMap locals:
      StackMap stack:
        36: iload 6 /* c */
            iload 5 /* paramLen */
            if_icmplt 23
        end local 6 // int c
        37: .line 320
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.resultColumns:[Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
            arraylength
            ifle 47
        38: .line 321
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.resultColumns:[Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
            arraylength
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        39: .line 322
            aload 1 /* bind */
            getfield io.reactiverse.pgclient.impl.codec.encoder.Bind.resultColumns:[Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
            dup
            astore 9
            arraylength
            istore 8
            iconst_0
            istore 7
            goto 45
      StackMap locals: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder io.reactiverse.pgclient.impl.codec.encoder.Bind java.lang.String java.util.List int int top int int io.reactiverse.pgclient.impl.codec.ColumnDesc[]
      StackMap stack:
        40: aload 9
            iload 7
            aaload
            astore 6 /* resultColumn */
        start local 6 // io.reactiverse.pgclient.impl.codec.ColumnDesc resultColumn
        41: .line 323
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            aload 6 /* resultColumn */
            invokevirtual io.reactiverse.pgclient.impl.codec.ColumnDesc.getDataType:()Lio/reactiverse/pgclient/impl/codec/DataType;
            getfield io.reactiverse.pgclient.impl.codec.DataType.supportsBinary:Z
            ifeq 42
            iconst_1
            goto 43
      StackMap locals: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder io.reactiverse.pgclient.impl.codec.encoder.Bind java.lang.String java.util.List int int io.reactiverse.pgclient.impl.codec.ColumnDesc int int io.reactiverse.pgclient.impl.codec.ColumnDesc[]
      StackMap stack: io.netty.buffer.ByteBuf
        42: iconst_0
      StackMap locals: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder io.reactiverse.pgclient.impl.codec.encoder.Bind java.lang.String java.util.List int int io.reactiverse.pgclient.impl.codec.ColumnDesc int int io.reactiverse.pgclient.impl.codec.ColumnDesc[]
      StackMap stack: io.netty.buffer.ByteBuf int
        43: invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        end local 6 // io.reactiverse.pgclient.impl.codec.ColumnDesc resultColumn
        44: .line 322
            iinc 7 1
      StackMap locals: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder io.reactiverse.pgclient.impl.codec.encoder.Bind java.lang.String java.util.List int int top int int io.reactiverse.pgclient.impl.codec.ColumnDesc[]
      StackMap stack:
        45: iload 7
            iload 8
            if_icmplt 40
        46: .line 325
            goto 49
        47: .line 326
      StackMap locals: io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder io.reactiverse.pgclient.impl.codec.encoder.Bind java.lang.String java.util.List int int
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_1
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        48: .line 327
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iconst_1
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
        49: .line 329
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            iload 4 /* pos */
            iconst_1
            iadd
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            invokevirtual io.netty.buffer.ByteBuf.writerIndex:()I
            iload 4 /* pos */
            isub
            iconst_1
            isub
            invokevirtual io.netty.buffer.ByteBuf.setInt:(II)Lio/netty/buffer/ByteBuf;
            pop
        50: .line 330
            return
        end local 5 // int paramLen
        end local 4 // int pos
        end local 3 // java.util.List paramValues
        end local 2 // java.lang.String portal
        end local 1 // io.reactiverse.pgclient.impl.codec.encoder.Bind bind
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   51     0          this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
            0   51     1          bind  Lio/reactiverse/pgclient/impl/codec/encoder/Bind;
            0   51     2        portal  Ljava/lang/String;
            0   51     3   paramValues  Ljava/util/List<Ljava/lang/Object;>;
            2   51     4           pos  I
           12   51     5      paramLen  I
           14   20     6             c  I
           22   37     6             c  I
           24   35     7         param  Ljava/lang/Object;
           28   35     8      dataType  Lio/reactiverse/pgclient/impl/codec/DataType;
           30   33     9           idx  I
           41   44     6  resultColumn  Lio/reactiverse/pgclient/impl/codec/ColumnDesc;
    Signature: (Lio/reactiverse/pgclient/impl/codec/encoder/Bind;Ljava/lang/String;Ljava/util/List<Ljava/lang/Object;>;)V
    MethodParameters:
             Name  Flags
      bind         
      portal       
      paramValues  

  private void ensureBuffer();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
         0: .line 333
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
            ifnonnull 2
         1: .line 334
            aload 0 /* this */
            aload 0 /* this */
            getfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.ctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
            invokeinterface io.netty.buffer.ByteBufAllocator.ioBuffer:()Lio/netty/buffer/ByteBuf;
            putfield io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder.out:Lio/netty/buffer/ByteBuf;
         2: .line 336
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactiverse.pgclient.impl.codec.encoder.MessageEncoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/reactiverse/pgclient/impl/codec/encoder/MessageEncoder;
}
SourceFile: "MessageEncoder.java"