public class examples.Examples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.Examples
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // examples.Examples this
         0: .line 40
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/Examples;

  public void gettingStarted();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // examples.Examples this
         0: .line 45
            new io.reactiverse.pgclient.PgPoolOptions
            dup
            invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
         1: .line 46
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         2: .line 47
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         3: .line 48
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         4: .line 49
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         5: .line 50
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         6: .line 51
            iconst_5
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         7: .line 45
            astore 1 /* options */
        start local 1 // io.reactiverse.pgclient.PgPoolOptions options
         8: .line 54
            aload 1 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            astore 2 /* client */
        start local 2 // io.reactiverse.pgclient.PgPool client
         9: .line 57
            aload 2 /* client */
            ldc "SELECT * FROM users WHERE id='julien'"
            aload 2 /* client */
            invokedynamic handle(Lio/reactiverse/pgclient/PgPool;)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
                  examples/Examples.lambda$0(Lio/reactiverse/pgclient/PgPool;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgPool;
            pop
        10: .line 68
            return
        end local 2 // io.reactiverse.pgclient.PgPool client
        end local 1 // io.reactiverse.pgclient.PgPoolOptions options
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0     this  Lexamples/Examples;
            8   11     1  options  Lio/reactiverse/pgclient/PgPoolOptions;
            9   11     2   client  Lio/reactiverse/pgclient/PgPool;

  public void configureFromEnv(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 73
            invokestatic io.reactiverse.pgclient.PgClient.pool:()Lio/reactiverse/pgclient/PgPool;
            pop
         1: .line 76
            aload 1 /* vertx */
            invokedynamic handle()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
                  examples/Examples.lambda$1(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokestatic io.reactiverse.pgclient.PgClient.connect:(Lio/vertx/core/Vertx;Lio/vertx/core/Handler;)V
         2: .line 79
            return
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    3     0   this  Lexamples/Examples;
            0    3     1  vertx  Lio/vertx/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public void configureFromUri(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 84
            ldc "postgresql://dbuser:secretpassword@database.server.com:3211/mydb"
            astore 2 /* connectionUri */
        start local 2 // java.lang.String connectionUri
         1: .line 87
            aload 2 /* connectionUri */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPool;
            pop
         2: .line 90
            aload 1 /* vertx */
            aload 2 /* connectionUri */
            invokedynamic handle()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
                  examples/Examples.lambda$2(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokestatic io.reactiverse.pgclient.PgClient.connect:(Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/core/Handler;)V
         3: .line 93
            return
        end local 2 // java.lang.String connectionUri
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0           this  Lexamples/Examples;
            0    4     1          vertx  Lio/vertx/core/Vertx;
            1    4     2  connectionUri  Ljava/lang/String;
    MethodParameters:
       Name  Flags
      vertx  

  public void connecting01();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // examples.Examples this
         0: .line 98
            new io.reactiverse.pgclient.PgPoolOptions
            dup
            invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
         1: .line 99
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         2: .line 100
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         3: .line 101
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         4: .line 102
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         5: .line 103
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         6: .line 104
            iconst_5
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         7: .line 98
            astore 1 /* options */
        start local 1 // io.reactiverse.pgclient.PgPoolOptions options
         8: .line 107
            aload 1 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            pop
         9: .line 108
            return
        end local 1 // io.reactiverse.pgclient.PgPoolOptions options
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   10     0     this  Lexamples/Examples;
            8   10     1  options  Lio/reactiverse/pgclient/PgPoolOptions;

  public void connecting02(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 113
            new io.reactiverse.pgclient.PgPoolOptions
            dup
            invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
         1: .line 114
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         2: .line 115
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         3: .line 116
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         4: .line 117
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         5: .line 118
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         6: .line 119
            iconst_5
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         7: .line 113
            astore 2 /* options */
        start local 2 // io.reactiverse.pgclient.PgPoolOptions options
         8: .line 122
            aload 1 /* vertx */
            aload 2 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            pop
         9: .line 123
            return
        end local 2 // io.reactiverse.pgclient.PgPoolOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   10     0     this  Lexamples/Examples;
            0   10     1    vertx  Lio/vertx/core/Vertx;
            8   10     2  options  Lio/reactiverse/pgclient/PgPoolOptions;
    MethodParameters:
       Name  Flags
      vertx  

  public void connecting03(io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgPool pool
         0: .line 128
            aload 1 /* pool */
            invokeinterface io.reactiverse.pgclient.PgPool.close:()V
         1: .line 129
            return
        end local 1 // io.reactiverse.pgclient.PgPool pool
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1  pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
      Name  Flags
      pool  

  public void connecting04(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 134
            new io.reactiverse.pgclient.PgPoolOptions
            dup
            invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
         1: .line 135
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         2: .line 136
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         3: .line 137
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         4: .line 138
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         5: .line 139
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         6: .line 140
            iconst_5
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         7: .line 134
            astore 2 /* options */
        start local 2 // io.reactiverse.pgclient.PgPoolOptions options
         8: .line 143
            aload 1 /* vertx */
            aload 2 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            astore 3 /* client */
        start local 3 // io.reactiverse.pgclient.PgPool client
         9: .line 146
            aload 3 /* client */
            invokedynamic handle()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
                  examples/Examples.lambda$3(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
        10: .line 171
            return
        end local 3 // io.reactiverse.pgclient.PgPool client
        end local 2 // io.reactiverse.pgclient.PgPoolOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0     this  Lexamples/Examples;
            0   11     1    vertx  Lio/vertx/core/Vertx;
            8   11     2  options  Lio/reactiverse/pgclient/PgPoolOptions;
            9   11     3   client  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
       Name  Flags
      vertx  

  public void connecting05(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 176
            new io.reactiverse.pgclient.PgConnectOptions
            dup
            invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
         1: .line 177
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
         2: .line 178
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         3: .line 179
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         4: .line 180
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         5: .line 181
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         6: .line 176
            astore 2 /* options */
        start local 2 // io.reactiverse.pgclient.PgConnectOptions options
         7: .line 184
            aload 1 /* vertx */
            aload 2 /* options */
            invokedynamic handle()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
                  examples/Examples.lambda$6(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokestatic io.reactiverse.pgclient.PgClient.connect:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;Lio/vertx/core/Handler;)V
         8: .line 208
            return
        end local 2 // io.reactiverse.pgclient.PgConnectOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lexamples/Examples;
            0    9     1    vertx  Lio/vertx/core/Vertx;
            7    9     2  options  Lio/reactiverse/pgclient/PgConnectOptions;
    MethodParameters:
       Name  Flags
      vertx  

  public void connecting06(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 214
            new io.reactiverse.pgclient.PgPoolOptions
            dup
            invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
         1: .line 215
            ldc "/var/run/postgresql"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         2: .line 216
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
         3: .line 217
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
         4: .line 214
            astore 2 /* options */
        start local 2 // io.reactiverse.pgclient.PgPoolOptions options
         5: .line 220
            aload 2 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            pop
         6: .line 224
            aload 1 /* vertx */
            aload 2 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            pop
         7: .line 225
            return
        end local 2 // io.reactiverse.pgclient.PgPoolOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lexamples/Examples;
            0    8     1    vertx  Lio/vertx/core/Vertx;
            5    8     2  options  Lio/reactiverse/pgclient/PgPoolOptions;
    MethodParameters:
       Name  Flags
      vertx  

  public void queries01(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 228
            aload 1 /* client */
            ldc "SELECT * FROM users WHERE id='julien'"
            invokedynamic handle()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
                  examples/Examples.lambda$9(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 236
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void queries02(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 239
            aload 1 /* client */
            ldc "SELECT * FROM users WHERE id=$1"
            ldc "julien"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokedynamic handle()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
                  examples/Examples.lambda$10(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedQuery:(Ljava/lang/String;Lio/reactiverse/pgclient/Tuple;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 247
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void queries03(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 250
            aload 1 /* client */
            ldc "SELECT first_name, last_name FROM users"
            invokedynamic handle()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
                  examples/Examples.lambda$11(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedQuery:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 260
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void queries04(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 263
            aload 1 /* client */
            ldc "INSERT INTO users (first_name, last_name) VALUES ($1, $2)"
            ldc "Julien"
            ldc "Viet"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokedynamic handle()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
                  examples/Examples.lambda$12(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedQuery:(Ljava/lang/String;Lio/reactiverse/pgclient/Tuple;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 271
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void queries05(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.Row row
         0: .line 274
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "User "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getString:(I)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* row */
            iconst_1
            invokeinterface io.reactiverse.pgclient.Row.getString:(I)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 275
            return
        end local 1 // io.reactiverse.pgclient.Row row
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1   row  Lio/reactiverse/pgclient/Row;
    MethodParameters:
      Name  Flags
      row   

  public void queries06(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.Row row
         0: .line 278
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "User "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* row */
            ldc "first_name"
            invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* row */
            ldc "last_name"
            invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 279
            return
        end local 1 // io.reactiverse.pgclient.Row row
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1   row  Lio/reactiverse/pgclient/Row;
    MethodParameters:
      Name  Flags
      row   

  public void queries07(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.Row row
         0: .line 283
            aload 1 /* row */
            ldc "first_name"
            invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            pop
         1: .line 284
            aload 1 /* row */
            ldc "male"
            invokeinterface io.reactiverse.pgclient.Row.getBoolean:(Ljava/lang/String;)Ljava/lang/Boolean;
            pop
         2: .line 285
            aload 1 /* row */
            ldc "age"
            invokeinterface io.reactiverse.pgclient.Row.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
            pop
         3: .line 289
            return
        end local 1 // io.reactiverse.pgclient.Row row
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lexamples/Examples;
            0    4     1   row  Lio/reactiverse/pgclient/Row;
    MethodParameters:
      Name  Flags
      row   

  public void queries08(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 294
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* batch */
        start local 2 // java.util.List batch
         1: .line 295
            aload 2 /* batch */
            ldc "julien"
            ldc "Julien Viet"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         2: .line 296
            aload 2 /* batch */
            ldc "emad"
            ldc "Emad Alblueshi"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         3: .line 299
            aload 1 /* client */
            ldc "INSERT INTO USERS (id, name) VALUES ($1, $2)"
            aload 2 /* batch */
            invokedynamic handle()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
                  examples/Examples.lambda$13(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedBatch:(Ljava/lang/String;Ljava/util/List;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         4: .line 308
            return
        end local 2 // java.util.List batch
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lexamples/Examples;
            0    5     1  client  Lio/reactiverse/pgclient/PgClient;
            1    5     2   batch  Ljava/util/List<Lio/reactiverse/pgclient/Tuple;>;
    MethodParameters:
        Name  Flags
      client  

  public void queries09(io.vertx.core.Vertx, io.reactiverse.pgclient.PgPoolOptions);
    descriptor: (Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.reactiverse.pgclient.PgPoolOptions options
         0: .line 313
            aload 2 /* options */
            iconst_1
            invokevirtual io.reactiverse.pgclient.PgPoolOptions.setCachePreparedStatements:(Z)Lio/reactiverse/pgclient/PgPoolOptions;
            pop
         1: .line 315
            aload 1 /* vertx */
            aload 2 /* options */
            invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
            pop
         2: .line 316
            return
        end local 2 // io.reactiverse.pgclient.PgPoolOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lexamples/Examples;
            0    3     1    vertx  Lio/vertx/core/Vertx;
            0    3     2  options  Lio/reactiverse/pgclient/PgPoolOptions;
    MethodParameters:
         Name  Flags
      vertx    
      options  

  public void queries10(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 319
            aload 1 /* client */
            ldc "INSERT INTO color (color_name) VALUES ($1), ($2), ($3) RETURNING color_id"
            ldc "white"
            ldc "red"
            ldc "blue"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokedynamic handle()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
                  examples/Examples.lambda$14(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedQuery:(Ljava/lang/String;Lio/reactiverse/pgclient/Tuple;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 330
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void usingConnections01(io.vertx.core.Vertx, io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.reactiverse.pgclient.PgPool pool
         0: .line 334
            aload 2 /* pool */
            invokedynamic handle()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
                  examples/Examples.lambda$15(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
         1: .line 351
            return
        end local 2 // io.reactiverse.pgclient.PgPool pool
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lexamples/Examples;
            0    2     1  vertx  Lio/vertx/core/Vertx;
            0    2     2   pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
       Name  Flags
      vertx  
      pool   

  public void usingConnections02(io.reactiverse.pgclient.PgConnection);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         0: .line 354
            aload 1 /* connection */
            ldc "SELECT * FROM users WHERE first_name LIKE $1"
            invokedynamic handle()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
                  examples/Examples.lambda$18(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.prepare:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         1: .line 365
            return
        end local 1 // io.reactiverse.pgclient.PgConnection connection
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lexamples/Examples;
            0    2     1  connection  Lio/reactiverse/pgclient/PgConnection;
    MethodParameters:
            Name  Flags
      connection  

  public void usingConnections03(io.reactiverse.pgclient.PgConnection);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         0: .line 368
            aload 1 /* connection */
            ldc "INSERT INTO USERS (id, name) VALUES ($1, $2)"
            invokedynamic handle()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
                  examples/Examples.lambda$20(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.prepare:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         1: .line 390
            return
        end local 1 // io.reactiverse.pgclient.PgConnection connection
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lexamples/Examples;
            0    2     1  connection  Lio/reactiverse/pgclient/PgConnection;
    MethodParameters:
            Name  Flags
      connection  

  public void transaction01(io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgPool pool
         0: .line 393
            aload 1 /* pool */
            invokedynamic handle()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
                  examples/Examples.lambda$22(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
         1: .line 419
            return
        end local 1 // io.reactiverse.pgclient.PgPool pool
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1  pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
      Name  Flags
      pool  

  public void transaction02(io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgPool pool
         0: .line 422
            aload 1 /* pool */
            invokedynamic handle()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
                  examples/Examples.lambda$26(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
         1: .line 457
            return
        end local 1 // io.reactiverse.pgclient.PgPool pool
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1  pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
      Name  Flags
      pool  

  public void transaction03(io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgPool pool
         0: .line 462
            aload 1 /* pool */
            invokedynamic handle()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
                  examples/Examples.lambda$31(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.begin:(Lio/vertx/core/Handler;)V
         1: .line 482
            return
        end local 1 // io.reactiverse.pgclient.PgPool pool
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1  pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
      Name  Flags
      pool  

  public void usingCursors01(io.reactiverse.pgclient.PgConnection);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         0: .line 485
            aload 1 /* connection */
            ldc "SELECT * FROM users WHERE first_name LIKE $1"
            aload 1 /* connection */
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$35(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.prepare:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         1: .line 511
            return
        end local 1 // io.reactiverse.pgclient.PgConnection connection
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lexamples/Examples;
            0    2     1  connection  Lio/reactiverse/pgclient/PgConnection;
    MethodParameters:
            Name  Flags
      connection  

  public void usingCursors02(io.reactiverse.pgclient.PgCursor);
    descriptor: (Lio/reactiverse/pgclient/PgCursor;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgCursor cursor
         0: .line 514
            aload 1 /* cursor */
            bipush 50
            aload 1 /* cursor */
            invokedynamic handle(Lio/reactiverse/pgclient/PgCursor;)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
                  examples/Examples.lambda$37(Lio/reactiverse/pgclient/PgCursor;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgCursor.read:(ILio/vertx/core/Handler;)V
         1: .line 520
            return
        end local 1 // io.reactiverse.pgclient.PgCursor cursor
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  cursor  Lio/reactiverse/pgclient/PgCursor;
    MethodParameters:
        Name  Flags
      cursor  

  public void usingCursors03(io.reactiverse.pgclient.PgConnection);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         0: .line 523
            aload 1 /* connection */
            ldc "SELECT * FROM users WHERE first_name LIKE $1"
            aload 1 /* connection */
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$38(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.prepare:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         1: .line 546
            return
        end local 1 // io.reactiverse.pgclient.PgConnection connection
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lexamples/Examples;
            0    2     1  connection  Lio/reactiverse/pgclient/PgConnection;
    MethodParameters:
            Name  Flags
      connection  

  public void typeMapping01(io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgPool pool
         0: .line 549
            aload 1 /* pool */
            ldc "SELECT 1::BIGINT \"VAL\""
            invokedynamic handle()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
                  examples/Examples.lambda$42(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgPool;
            pop
         1: .line 559
            return
        end local 1 // io.reactiverse.pgclient.PgPool pool
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1  pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
      Name  Flags
      pool  

  public void typeMapping02(io.reactiverse.pgclient.PgPool);
    descriptor: (Lio/reactiverse/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgPool pool
         0: .line 562
            aload 1 /* pool */
            ldc "SELECT 1::BIGINT \"VAL\""
            invokedynamic handle()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
                  examples/Examples.lambda$43(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPool.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgPool;
            pop
         1: .line 573
            return
        end local 1 // io.reactiverse.pgclient.PgPool pool
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/Examples;
            0    2     1  pool  Lio/reactiverse/pgclient/PgPool;
    MethodParameters:
      Name  Flags
      pool  

  public void pubsub01(io.reactiverse.pgclient.PgConnection);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         0: .line 577
            aload 1 /* connection */
            invokedynamic handle()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
                  examples/Examples.lambda$44(Lio/reactiverse/pgclient/PgNotification;)V (6)
                  (Lio/reactiverse/pgclient/PgNotification;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.notificationHandler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         1: .line 581
            aload 1 /* connection */
            ldc "LISTEN some-channel"
            invokedynamic handle()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
                  examples/Examples.lambda$45(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         2: .line 584
            return
        end local 1 // io.reactiverse.pgclient.PgConnection connection
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lexamples/Examples;
            0    3     1  connection  Lio/reactiverse/pgclient/PgConnection;
    MethodParameters:
            Name  Flags
      connection  

  public void pubsub02(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 588
            aload 1 /* vertx */
            new io.reactiverse.pgclient.PgConnectOptions
            dup
            invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
         1: .line 589
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
         2: .line 590
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         3: .line 591
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         4: .line 592
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         5: .line 593
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         6: .line 588
            invokestatic io.reactiverse.pgclient.pubsub.PgSubscriber.subscriber:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
            astore 2 /* subscriber */
        start local 2 // io.reactiverse.pgclient.pubsub.PgSubscriber subscriber
         7: .line 597
            aload 2 /* subscriber */
            ldc "channel1"
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            invokedynamic handle()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
                  examples/Examples.lambda$46(Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.handler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         8: .line 601
            aload 2 /* subscriber */
            aload 2 /* subscriber */
            invokedynamic handle(Lio/reactiverse/pgclient/pubsub/PgSubscriber;)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
                  examples/Examples.lambda$47(Lio/reactiverse/pgclient/pubsub/PgSubscriber;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.connect:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
            pop
         9: .line 610
            return
        end local 2 // io.reactiverse.pgclient.pubsub.PgSubscriber subscriber
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0        this  Lexamples/Examples;
            0   10     1       vertx  Lio/vertx/core/Vertx;
            7   10     2  subscriber  Lio/reactiverse/pgclient/pubsub/PgSubscriber;
    MethodParameters:
       Name  Flags
      vertx  

  public void pubsub03(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 614
            aload 1 /* vertx */
            new io.reactiverse.pgclient.PgConnectOptions
            dup
            invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
         1: .line 615
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
         2: .line 616
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         3: .line 617
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         4: .line 618
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         5: .line 619
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         6: .line 614
            invokestatic io.reactiverse.pgclient.pubsub.PgSubscriber.subscriber:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
            astore 2 /* subscriber */
        start local 2 // io.reactiverse.pgclient.pubsub.PgSubscriber subscriber
         7: .line 622
            aload 2 /* subscriber */
            aload 2 /* subscriber */
            invokedynamic handle(Lio/reactiverse/pgclient/pubsub/PgSubscriber;)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
                  examples/Examples.lambda$49(Lio/reactiverse/pgclient/pubsub/PgSubscriber;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.connect:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
            pop
         8: .line 656
            return
        end local 2 // io.reactiverse.pgclient.pubsub.PgSubscriber subscriber
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    9     0        this  Lexamples/Examples;
            0    9     1       vertx  Lio/vertx/core/Vertx;
            7    9     2  subscriber  Lio/reactiverse/pgclient/pubsub/PgSubscriber;
    MethodParameters:
       Name  Flags
      vertx  

  public void pubsub04(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 660
            aload 1 /* vertx */
            new io.reactiverse.pgclient.PgConnectOptions
            dup
            invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
         1: .line 661
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
         2: .line 662
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         3: .line 663
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         4: .line 664
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         5: .line 665
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         6: .line 660
            invokestatic io.reactiverse.pgclient.pubsub.PgSubscriber.subscriber:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
            astore 2 /* subscriber */
        start local 2 // io.reactiverse.pgclient.pubsub.PgSubscriber subscriber
         7: .line 669
            aload 2 /* subscriber */
            invokedynamic apply()Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  examples/Examples.lambda$57(Ljava/lang/Integer;)Ljava/lang/Long; (6)
                  (Ljava/lang/Integer;)Ljava/lang/Long;
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.reconnectPolicy:(Ljava/util/function/Function;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
            pop
         8: .line 676
            return
        end local 2 // io.reactiverse.pgclient.pubsub.PgSubscriber subscriber
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    9     0        this  Lexamples/Examples;
            0    9     1       vertx  Lio/vertx/core/Vertx;
            7    9     2  subscriber  Lio/reactiverse/pgclient/pubsub/PgSubscriber;
    MethodParameters:
       Name  Flags
      vertx  

  public void ex10(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 680
            new io.reactiverse.pgclient.PgConnectOptions
            dup
            invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
         1: .line 681
            sipush 5432
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
         2: .line 682
            ldc "the-host"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         3: .line 683
            ldc "the-db"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         4: .line 684
            ldc "user"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         5: .line 685
            ldc "secret"
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
         6: .line 686
            getstatic io.reactiverse.pgclient.SslMode.VERIFY_CA:Lio/reactiverse/pgclient/SslMode;
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setSslMode:(Lio/reactiverse/pgclient/SslMode;)Lio/reactiverse/pgclient/PgConnectOptions;
         7: .line 687
            new io.vertx.core.net.PemTrustOptions
            dup
            invokespecial io.vertx.core.net.PemTrustOptions.<init>:()V
            ldc "/path/to/cert.pem"
            invokevirtual io.vertx.core.net.PemTrustOptions.addCertPath:(Ljava/lang/String;)Lio/vertx/core/net/PemTrustOptions;
            invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPemTrustOptions:(Lio/vertx/core/net/PemTrustOptions;)Lio/reactiverse/pgclient/PgConnectOptions;
         8: .line 680
            astore 2 /* options */
        start local 2 // io.reactiverse.pgclient.PgConnectOptions options
         9: .line 689
            aload 1 /* vertx */
            aload 2 /* options */
            invokedynamic handle()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
                  examples/Examples.lambda$58(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokestatic io.reactiverse.pgclient.PgClient.connect:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;Lio/vertx/core/Handler;)V
        10: .line 696
            return
        end local 2 // io.reactiverse.pgclient.PgConnectOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0     this  Lexamples/Examples;
            0   11     1    vertx  Lio/vertx/core/Vertx;
            9   11     2  options  Lio/reactiverse/pgclient/PgConnectOptions;
    MethodParameters:
       Name  Flags
      vertx  

  public void jsonExample();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // examples.Examples this
         0: .line 702
            aconst_null
            invokestatic io.reactiverse.pgclient.data.Json.create:(Ljava/lang/Object;)Lio/reactiverse/pgclient/data/Json;
            invokestatic io.reactiverse.pgclient.data.Json.create:(Ljava/lang/Object;)Lio/reactiverse/pgclient/data/Json;
         1: .line 703
            new io.vertx.core.json.JsonObject
            dup
            invokespecial io.vertx.core.json.JsonObject.<init>:()V
            ldc "foo"
            ldc "bar"
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
            invokestatic io.reactiverse.pgclient.data.Json.create:(Ljava/lang/Object;)Lio/reactiverse/pgclient/data/Json;
            invokestatic io.reactiverse.pgclient.data.Json.create:(Ljava/lang/Object;)Lio/reactiverse/pgclient/data/Json;
         2: .line 704
            aconst_null
            invokestatic io.reactiverse.pgclient.data.Json.create:(Ljava/lang/Object;)Lio/reactiverse/pgclient/data/Json;
            invokestatic io.reactiverse.pgclient.data.Json.create:(Ljava/lang/Object;)Lio/reactiverse/pgclient/data/Json;
         3: .line 701
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            astore 1 /* tuple */
        start local 1 // io.reactiverse.pgclient.Tuple tuple
         4: .line 707
            aload 1 /* tuple */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Tuple.getJson:(I)Lio/reactiverse/pgclient/data/Json;
            invokeinterface io.reactiverse.pgclient.data.Json.value:()Ljava/lang/Object;
            pop
         5: .line 710
            aload 1 /* tuple */
            iconst_1
            invokeinterface io.reactiverse.pgclient.Tuple.getJson:(I)Lio/reactiverse/pgclient/data/Json;
            invokeinterface io.reactiverse.pgclient.data.Json.value:()Ljava/lang/Object;
            pop
         6: .line 713
            aload 1 /* tuple */
            iconst_3
            invokeinterface io.reactiverse.pgclient.Tuple.getJson:(I)Lio/reactiverse/pgclient/data/Json;
            invokeinterface io.reactiverse.pgclient.data.Json.value:()Ljava/lang/Object;
            pop
         7: .line 714
            return
        end local 1 // io.reactiverse.pgclient.Tuple tuple
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    8     0   this  Lexamples/Examples;
            4    8     1  tuple  Lio/reactiverse/pgclient/Tuple;

  public void numericExample(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.Row row
         0: .line 717
            aload 1 /* row */
            ldc "value"
            invokeinterface io.reactiverse.pgclient.Row.getNumeric:(Ljava/lang/String;)Lio/reactiverse/pgclient/data/Numeric;
            astore 2 /* numeric */
        start local 2 // io.reactiverse.pgclient.data.Numeric numeric
         1: .line 718
            aload 2 /* numeric */
            invokevirtual io.reactiverse.pgclient.data.Numeric.isNaN:()Z
            ifne 3
         2: .line 721
            aload 2 /* numeric */
            invokevirtual io.reactiverse.pgclient.data.Numeric.bigDecimalValue:()Ljava/math/BigDecimal;
            pop
         3: .line 723
      StackMap locals: io.reactiverse.pgclient.data.Numeric
      StackMap stack:
            return
        end local 2 // io.reactiverse.pgclient.data.Numeric numeric
        end local 1 // io.reactiverse.pgclient.Row row
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lexamples/Examples;
            0    4     1      row  Lio/reactiverse/pgclient/Row;
            1    4     2  numeric  Lio/reactiverse/pgclient/data/Numeric;
    MethodParameters:
      Name  Flags
      row   

  public void arrayExample();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=1
        start local 0 // examples.Examples this
         0: .line 727
            iconst_4
            anewarray java.lang.String
            dup
            iconst_0
            ldc "a"
            aastore
            dup
            iconst_1
            ldc "tuple"
            aastore
            dup
            iconst_2
            ldc "with"
            aastore
            dup
            iconst_3
            ldc "arrays"
            aastore
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            astore 1 /* tuple */
        start local 1 // io.reactiverse.pgclient.Tuple tuple
         1: .line 730
            aload 1 /* tuple */
            iconst_2
            anewarray java.lang.String
            dup
            iconst_0
            ldc "another"
            aastore
            dup
            iconst_1
            ldc "array"
            aastore
            invokeinterface io.reactiverse.pgclient.Tuple.addStringArray:([Ljava/lang/String;)Lio/reactiverse/pgclient/Tuple;
            pop
         2: .line 733
            aload 1 /* tuple */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Tuple.getStringArray:(I)[Ljava/lang/String;
            pop
         3: .line 734
            return
        end local 1 // io.reactiverse.pgclient.Tuple tuple
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lexamples/Examples;
            1    4     1  tuple  Lio/reactiverse/pgclient/Tuple;

  public void customType01Example(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 737
            aload 1 /* client */
            ldc "SELECT address, (address).city FROM address_book WHERE id=$1"
            iconst_3
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokedynamic handle()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
                  examples/Examples.lambda$59(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedQuery:(Ljava/lang/String;Lio/reactiverse/pgclient/Tuple;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 747
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void customType02Example(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 750
            aload 1 /* client */
            ldc "INSERT INTO address_book (id, address) VALUES ($1, $2)"
            iconst_3
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            ldc "('Anytown', 'Second Ave', false)"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokedynamic handle()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
                  examples/Examples.lambda$60(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgClient.preparedQuery:(Ljava/lang/String;Lio/reactiverse/pgclient/Tuple;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         1: .line 758
            return
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/Examples;
            0    2     1  client  Lio/reactiverse/pgclient/PgClient;
    MethodParameters:
        Name  Flags
      client  

  public void collector01Example(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 764
            invokedynamic apply()Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  examples/Examples.lambda$61(Lio/reactiverse/pgclient/Row;)Ljava/lang/Long; (6)
                  (Lio/reactiverse/pgclient/Row;)Ljava/lang/Long;
         1: .line 765
            invokedynamic apply()Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  examples/Examples.lambda$62(Lio/reactiverse/pgclient/Row;)Ljava/lang/String; (6)
                  (Lio/reactiverse/pgclient/Row;)Ljava/lang/String;
         2: .line 763
            invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
            astore 2 /* collector */
        start local 2 // java.util.stream.Collector collector
         3: .line 768
            aload 1 /* client */
            ldc "SELECT * FROM users"
         4: .line 769
            aload 2 /* collector */
         5: .line 770
            invokedynamic handle()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
                  examples/Examples.lambda$63(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
         6: .line 768
            invokeinterface io.reactiverse.pgclient.PgClient.query:(Ljava/lang/String;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         7: .line 781
            return
        end local 2 // java.util.stream.Collector collector
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    8     0       this  Lexamples/Examples;
            0    8     1     client  Lio/reactiverse/pgclient/PgClient;
            3    8     2  collector  Ljava/util/stream/Collector<Lio/reactiverse/pgclient/Row;*Ljava/util/Map<Ljava/lang/Long;Ljava/lang/String;>;>;
    MethodParameters:
        Name  Flags
      client  

  public void collector02Example(io.reactiverse.pgclient.PgClient);
    descriptor: (Lio/reactiverse/pgclient/PgClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgClient client
         0: .line 787
            invokedynamic apply()Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  examples/Examples.lambda$64(Lio/reactiverse/pgclient/Row;)Ljava/lang/String; (6)
                  (Lio/reactiverse/pgclient/Row;)Ljava/lang/String;
         1: .line 788
            ldc ","
            ldc "("
            ldc ")"
            invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
         2: .line 786
            invokestatic java.util.stream.Collectors.mapping:(Ljava/util/function/Function;Ljava/util/stream/Collector;)Ljava/util/stream/Collector;
            astore 2 /* collector */
        start local 2 // java.util.stream.Collector collector
         3: .line 792
            aload 1 /* client */
            ldc "SELECT * FROM users"
         4: .line 793
            aload 2 /* collector */
         5: .line 794
            invokedynamic handle()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
                  examples/Examples.lambda$65(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
         6: .line 792
            invokeinterface io.reactiverse.pgclient.PgClient.query:(Ljava/lang/String;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
            pop
         7: .line 805
            return
        end local 2 // java.util.stream.Collector collector
        end local 1 // io.reactiverse.pgclient.PgClient client
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    8     0       this  Lexamples/Examples;
            0    8     1     client  Lio/reactiverse/pgclient/PgClient;
            3    8     2  collector  Ljava/util/stream/Collector<Lio/reactiverse/pgclient/Row;*Ljava/lang/String;>;
    MethodParameters:
        Name  Flags
      client  

  public void cancelRequest(io.reactiverse.pgclient.PgConnection);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.Examples this
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         0: .line 808
            aload 1 /* connection */
            ldc "SELECT pg_sleep(20)"
            invokedynamic handle()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
                  examples/Examples.lambda$66(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         1: .line 817
            aload 1 /* connection */
            invokedynamic handle()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
                  examples/Examples.lambda$67(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.cancelRequest:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         2: .line 824
            return
        end local 1 // io.reactiverse.pgclient.PgConnection connection
        end local 0 // examples.Examples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lexamples/Examples;
            0    3     1  connection  Lio/reactiverse/pgclient/PgConnection;
    MethodParameters:
            Name  Flags
      connection  

  private static void lambda$0(io.reactiverse.pgclient.PgPool, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgPool;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar
         0: .line 58
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 59
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 2 /* result */
        start local 2 // io.reactiverse.pgclient.PgRowSet result
         2: .line 60
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* result */
            invokeinterface io.reactiverse.pgclient.PgRowSet.size:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " rows "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.reactiverse.pgclient.PgRowSet result
         3: .line 61
            goto 5
         4: .line 62
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 66
      StackMap locals:
      StackMap stack:
            aload 0
            invokeinterface io.reactiverse.pgclient.PgPool.close:()V
         6: .line 67
            return
        end local 1 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     1      ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    3     2  result  Lio/reactiverse/pgclient/PgRowSet;

  private static void lambda$1(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 78
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;

  private static void lambda$2(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 92
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;

  private static void lambda$3(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar1
         0: .line 148
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 150
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Connected"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 153
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgConnection
            astore 1 /* conn */
        start local 1 // io.reactiverse.pgclient.PgConnection conn
         3: .line 156
            aload 1 /* conn */
            ldc "SELECT * FROM users WHERE id='julien'"
            aload 1 /* conn */
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$4(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
        end local 1 // io.reactiverse.pgclient.PgConnection conn
         4: .line 167
            goto 6
         5: .line 168
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Could not connect: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         6: .line 170
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0   ar1  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;
            3    4     1  conn  Lio/reactiverse/pgclient/PgConnection;

  private static void lambda$6(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 185
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 187
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Connected"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 190
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgConnection
            astore 1 /* conn */
        start local 1 // io.reactiverse.pgclient.PgConnection conn
         3: .line 193
            aload 1 /* conn */
            ldc "SELECT * FROM users WHERE id='julien'"
            aload 1 /* conn */
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$7(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
        end local 1 // io.reactiverse.pgclient.PgConnection conn
         4: .line 204
            goto 6
         5: .line 205
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Could not connect: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         6: .line 207
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;
            3    4     1  conn  Lio/reactiverse/pgclient/PgConnection;

  private static void lambda$9(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 229
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 230
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* result */
        start local 1 // io.reactiverse.pgclient.PgRowSet result
         2: .line 231
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* result */
            invokeinterface io.reactiverse.pgclient.PgRowSet.size:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " rows "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 1 // io.reactiverse.pgclient.PgRowSet result
         3: .line 232
            goto 5
         4: .line 233
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 235
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0      ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    3     1  result  Lio/reactiverse/pgclient/PgRowSet;

  private static void lambda$10(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 240
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 241
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rows */
        start local 1 // io.reactiverse.pgclient.PgRowSet rows
         2: .line 242
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.size:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " rows "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 1 // io.reactiverse.pgclient.PgRowSet rows
         3: .line 243
            goto 5
         4: .line 244
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 246
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    3     1  rows  Lio/reactiverse/pgclient/PgRowSet;

  private static void lambda$11(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 251
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 7
         1: .line 252
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rows */
        start local 1 // io.reactiverse.pgclient.PgRowSet rows
         2: .line 253
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Ljava/util/Iterator;
            astore 3
            goto 5
      StackMap locals: io.vertx.core.AsyncResult io.reactiverse.pgclient.PgRowSet top java.util.Iterator
      StackMap stack:
         3: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.Row
            astore 2 /* row */
        start local 2 // io.reactiverse.pgclient.Row row
         4: .line 254
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "User "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getString:(I)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* row */
            iconst_1
            invokeinterface io.reactiverse.pgclient.Row.getString:(I)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.reactiverse.pgclient.Row row
         5: .line 253
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
        end local 1 // io.reactiverse.pgclient.PgRowSet rows
         6: .line 256
            goto 8
         7: .line 257
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         8: .line 259
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    6     1  rows  Lio/reactiverse/pgclient/PgRowSet;
            4    5     2   row  Lio/reactiverse/pgclient/Row;

  private static void lambda$12(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 264
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 265
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rows */
        start local 1 // io.reactiverse.pgclient.PgRowSet rows
         2: .line 266
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.rowCount:()I
            invokevirtual java.io.PrintStream.println:(I)V
        end local 1 // io.reactiverse.pgclient.PgRowSet rows
         3: .line 267
            goto 5
         4: .line 268
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 270
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    3     1  rows  Lio/reactiverse/pgclient/PgRowSet;

  private static void lambda$13(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 300
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 303
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            pop
         2: .line 304
            goto 4
         3: .line 305
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Batch failed "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 307
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$14(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 320
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 8
         1: .line 321
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rows */
        start local 1 // io.reactiverse.pgclient.PgRowSet rows
         2: .line 322
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.rowCount:()I
            invokevirtual java.io.PrintStream.println:(I)V
         3: .line 323
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Ljava/util/Iterator;
            astore 3
            goto 6
      StackMap locals: io.vertx.core.AsyncResult io.reactiverse.pgclient.PgRowSet top java.util.Iterator
      StackMap stack:
         4: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.Row
            astore 2 /* row */
        start local 2 // io.reactiverse.pgclient.Row row
         5: .line 324
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "generated key: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* row */
            ldc "color_id"
            invokeinterface io.reactiverse.pgclient.Row.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.reactiverse.pgclient.Row row
         6: .line 323
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
        end local 1 // io.reactiverse.pgclient.PgRowSet rows
         7: .line 326
            goto 9
         8: .line 327
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         9: .line 329
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    7     1  rows  Lio/reactiverse/pgclient/PgRowSet;
            5    6     2   row  Lio/reactiverse/pgclient/Row;

  private static void lambda$15(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar1
         0: .line 335
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 336
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgConnection
            astore 1 /* connection */
        start local 1 // io.reactiverse.pgclient.PgConnection connection
         2: .line 338
            aload 1 /* connection */
            ldc "SELECT * FROM users WHERE id='julien'"
            aload 0 /* ar1 */
            aload 1 /* connection */
            invokedynamic handle(Lio/vertx/core/AsyncResult;Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$16(Lio/vertx/core/AsyncResult;Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
        end local 1 // io.reactiverse.pgclient.PgConnection connection
         3: .line 350
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0         ar1  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;
            2    3     1  connection  Lio/reactiverse/pgclient/PgConnection;

  private static void lambda$18(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar1
         0: .line 355
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 356
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgPreparedQuery
            astore 1 /* pq */
        start local 1 // io.reactiverse.pgclient.PgPreparedQuery pq
         2: .line 357
            aload 1 /* pq */
            ldc "julien"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokedynamic handle()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
                  examples/Examples.lambda$19(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPreparedQuery.execute:(Lio/reactiverse/pgclient/Tuple;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgPreparedQuery;
            pop
        end local 1 // io.reactiverse.pgclient.PgPreparedQuery pq
         3: .line 364
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0   ar1  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgPreparedQuery;>;
            2    3     1    pq  Lio/reactiverse/pgclient/PgPreparedQuery;

  private static void lambda$20(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar1
         0: .line 369
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 6
         1: .line 370
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgPreparedQuery
            astore 1 /* prepared */
        start local 1 // io.reactiverse.pgclient.PgPreparedQuery prepared
         2: .line 373
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* batch */
        start local 2 // java.util.List batch
         3: .line 376
            aload 2 /* batch */
            ldc "julien"
            ldc "Julien Viet"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         4: .line 377
            aload 2 /* batch */
            ldc "emad"
            ldc "Emad Alblueshi"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         5: .line 379
            aload 1 /* prepared */
            aload 2 /* batch */
            invokedynamic handle()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
                  examples/Examples.lambda$21(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgPreparedQuery.batch:(Ljava/util/List;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgPreparedQuery;
            pop
        end local 2 // java.util.List batch
        end local 1 // io.reactiverse.pgclient.PgPreparedQuery prepared
         6: .line 389
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0       ar1  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgPreparedQuery;>;
            2    6     1  prepared  Lio/reactiverse/pgclient/PgPreparedQuery;
            3    6     2     batch  Ljava/util/List<Lio/reactiverse/pgclient/Tuple;>;

  private static void lambda$22(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 394
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 6
         1: .line 397
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgConnection
            astore 1 /* conn */
        start local 1 // io.reactiverse.pgclient.PgConnection conn
         2: .line 400
            aload 1 /* conn */
            invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
            astore 2 /* tx */
        start local 2 // io.reactiverse.pgclient.PgTransaction tx
         3: .line 403
            aload 1 /* conn */
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
            invokedynamic handle()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
                  examples/Examples.lambda$23(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         4: .line 404
            aload 1 /* conn */
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Emad','Alblueshi')"
            invokedynamic handle()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
                  examples/Examples.lambda$24(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         5: .line 407
            aload 2 /* tx */
            aload 1 /* conn */
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$25(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgTransaction.commit:(Lio/vertx/core/Handler;)V
        end local 2 // io.reactiverse.pgclient.PgTransaction tx
        end local 1 // io.reactiverse.pgclient.PgConnection conn
         6: .line 418
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;
            2    6     1  conn  Lio/reactiverse/pgclient/PgConnection;
            3    6     2    tx  Lio/reactiverse/pgclient/PgTransaction;

  private static void lambda$26(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 423
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 9
         1: .line 426
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgConnection
            astore 1 /* conn */
        start local 1 // io.reactiverse.pgclient.PgConnection conn
         2: .line 429
            aload 1 /* conn */
         3: .line 430
            invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
         4: .line 431
            invokedynamic handle()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
                  examples/Examples.lambda$27(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.reactiverse.pgclient.PgTransaction.abortHandler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgTransaction;
         5: .line 429
            astore 2 /* tx */
        start local 2 // io.reactiverse.pgclient.PgTransaction tx
         6: .line 435
            aload 1 /* conn */
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
            aload 2 /* tx */
            aload 1 /* conn */
            invokedynamic handle(Lio/reactiverse/pgclient/PgTransaction;Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$28(Lio/reactiverse/pgclient/PgTransaction;Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         7: .line 444
            aload 1 /* conn */
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
            invokedynamic handle()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
                  examples/Examples.lambda$29(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         8: .line 449
            aload 2 /* tx */
            aload 1 /* conn */
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$30(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgTransaction.commit:(Lio/vertx/core/Handler;)V
        end local 2 // io.reactiverse.pgclient.PgTransaction tx
        end local 1 // io.reactiverse.pgclient.PgConnection conn
         9: .line 456
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;
            2    9     1  conn  Lio/reactiverse/pgclient/PgConnection;
            6    9     2    tx  Lio/reactiverse/pgclient/PgTransaction;

  private static void lambda$31(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 463
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 466
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgTransaction
            astore 1 /* tx */
        start local 1 // io.reactiverse.pgclient.PgTransaction tx
         2: .line 469
            aload 1 /* tx */
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
            invokedynamic handle()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
                  examples/Examples.lambda$32(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgTransaction.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgTransaction;
            pop
         3: .line 470
            aload 1 /* tx */
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Emad','Alblueshi')"
            invokedynamic handle()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
                  examples/Examples.lambda$33(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgTransaction.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgTransaction;
            pop
         4: .line 473
            aload 1 /* tx */
            invokedynamic handle()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
                  examples/Examples.lambda$34(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgTransaction.commit:(Lio/vertx/core/Handler;)V
        end local 1 // io.reactiverse.pgclient.PgTransaction tx
         5: .line 481
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgTransaction;>;
            2    5     1    tx  Lio/reactiverse/pgclient/PgTransaction;

  private static void lambda$35(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=5, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar1
         0: .line 486
            aload 1 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 487
            aload 1 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgPreparedQuery
            astore 2 /* pq */
        start local 2 // io.reactiverse.pgclient.PgPreparedQuery pq
         2: .line 490
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
            astore 3 /* tx */
        start local 3 // io.reactiverse.pgclient.PgTransaction tx
         3: .line 493
            aload 2 /* pq */
            ldc "julien"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokeinterface io.reactiverse.pgclient.PgPreparedQuery.cursor:(Lio/reactiverse/pgclient/Tuple;)Lio/reactiverse/pgclient/PgCursor;
            astore 4 /* cursor */
        start local 4 // io.reactiverse.pgclient.PgCursor cursor
         4: .line 496
            aload 4 /* cursor */
            bipush 50
            aload 4 /* cursor */
            aload 3 /* tx */
            invokedynamic handle(Lio/reactiverse/pgclient/PgCursor;Lio/reactiverse/pgclient/PgTransaction;)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
                  examples/Examples.lambda$36(Lio/reactiverse/pgclient/PgCursor;Lio/reactiverse/pgclient/PgTransaction;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgCursor.read:(ILio/vertx/core/Handler;)V
        end local 4 // io.reactiverse.pgclient.PgCursor cursor
        end local 3 // io.reactiverse.pgclient.PgTransaction tx
        end local 2 // io.reactiverse.pgclient.PgPreparedQuery pq
         5: .line 510
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     1     ar1  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgPreparedQuery;>;
            2    5     2      pq  Lio/reactiverse/pgclient/PgPreparedQuery;
            3    5     3      tx  Lio/reactiverse/pgclient/PgTransaction;
            4    5     4  cursor  Lio/reactiverse/pgclient/PgCursor;

  private static void lambda$37(io.reactiverse.pgclient.PgCursor, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgCursor;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar2
         0: .line 515
            aload 1 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 517
            aload 0
            invokeinterface io.reactiverse.pgclient.PgCursor.close:()V
         2: .line 519
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     1   ar2  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$38(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar1
         0: .line 524
            aload 1 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 7
         1: .line 525
            aload 1 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgPreparedQuery
            astore 2 /* pq */
        start local 2 // io.reactiverse.pgclient.PgPreparedQuery pq
         2: .line 528
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
            astore 3 /* tx */
        start local 3 // io.reactiverse.pgclient.PgTransaction tx
         3: .line 531
            aload 2 /* pq */
            bipush 50
            ldc "julien"
            invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
            invokeinterface io.reactiverse.pgclient.PgPreparedQuery.createStream:(ILio/reactiverse/pgclient/Tuple;)Lio/reactiverse/pgclient/PgStream;
            astore 4 /* stream */
        start local 4 // io.reactiverse.pgclient.PgStream stream
         4: .line 534
            aload 4 /* stream */
            invokedynamic handle()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
                  examples/Examples.lambda$39(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.reactiverse.pgclient.PgStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgStream;
            pop
         5: .line 537
            aload 4 /* stream */
            aload 3 /* tx */
            invokedynamic handle(Lio/reactiverse/pgclient/PgTransaction;)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
                  examples/Examples.lambda$40(Lio/reactiverse/pgclient/PgTransaction;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.reactiverse.pgclient.PgStream.endHandler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgStream;
            pop
         6: .line 541
            aload 4 /* stream */
            invokedynamic handle()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
                  examples/Examples.lambda$41(Lio/reactiverse/pgclient/Row;)V (6)
                  (Lio/reactiverse/pgclient/Row;)V
            invokeinterface io.reactiverse.pgclient.PgStream.handler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgStream;
            pop
        end local 4 // io.reactiverse.pgclient.PgStream stream
        end local 3 // io.reactiverse.pgclient.PgTransaction tx
        end local 2 // io.reactiverse.pgclient.PgPreparedQuery pq
         7: .line 545
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     1     ar1  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgPreparedQuery;>;
            2    7     2      pq  Lio/reactiverse/pgclient/PgPreparedQuery;
            3    7     3      tx  Lio/reactiverse/pgclient/PgTransaction;
            4    7     4  stream  Lio/reactiverse/pgclient/PgStream<Lio/reactiverse/pgclient/Row;>;

  private static void lambda$42(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 550
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rowSet */
        start local 1 // io.reactiverse.pgclient.PgRowSet rowSet
         1: .line 551
            aload 1 /* rowSet */
            invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Lio/reactiverse/pgclient/PgIterator;
            invokeinterface io.reactiverse.pgclient.PgIterator.next:()Lio/reactiverse/pgclient/Row;
            astore 2 /* row */
        start local 2 // io.reactiverse.pgclient.Row row
         2: .line 554
            aload 2 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getValue:(I)Ljava/lang/Object;
            pop
         3: .line 557
            aload 2 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getInteger:(I)Ljava/lang/Integer;
            pop
        end local 2 // io.reactiverse.pgclient.Row row
        end local 1 // io.reactiverse.pgclient.PgRowSet rowSet
         4: .line 558
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0      ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            1    4     1  rowSet  Lio/reactiverse/pgclient/PgRowSet;
            2    4     2     row  Lio/reactiverse/pgclient/Row;

  private static void lambda$43(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 563
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rowSet */
        start local 1 // io.reactiverse.pgclient.PgRowSet rowSet
         1: .line 564
            aload 1 /* rowSet */
            invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Lio/reactiverse/pgclient/PgIterator;
            invokeinterface io.reactiverse.pgclient.PgIterator.next:()Lio/reactiverse/pgclient/Row;
            astore 2 /* row */
        start local 2 // io.reactiverse.pgclient.Row row
         2: .line 567
            aload 2 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getValue:(I)Ljava/lang/Object;
            pop
         3: .line 570
            aload 2 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getInteger:(I)Ljava/lang/Integer;
            pop
        end local 2 // io.reactiverse.pgclient.Row row
        end local 1 // io.reactiverse.pgclient.PgRowSet rowSet
         4: .line 571
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0      ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            1    4     1  rowSet  Lio/reactiverse/pgclient/PgRowSet;
            2    4     2     row  Lio/reactiverse/pgclient/Row;

  private static void lambda$44(io.reactiverse.pgclient.PgNotification);
    descriptor: (Lio/reactiverse/pgclient/PgNotification;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.PgNotification notification
         0: .line 578
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Received "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* notification */
            invokevirtual io.reactiverse.pgclient.PgNotification.getPayload:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " on channel "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* notification */
            invokevirtual io.reactiverse.pgclient.PgNotification.getChannel:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 579
            return
        end local 0 // io.reactiverse.pgclient.PgNotification notification
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    2     0  notification  Lio/reactiverse/pgclient/PgNotification;

  private static void lambda$45(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 582
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Subscribed to channel"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 583
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$46(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.String payload
         0: .line 598
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Received "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* payload */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 599
            return
        end local 0 // java.lang.String payload
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  payload  Ljava/lang/String;

  private static void lambda$47(io.reactiverse.pgclient.pubsub.PgSubscriber, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/pubsub/PgSubscriber;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar
         0: .line 602
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 605
            aload 0
            ldc "channel2"
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            invokedynamic handle()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
                  examples/Examples.lambda$48(Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.handler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         2: .line 609
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     1    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$49(io.reactiverse.pgclient.pubsub.PgSubscriber, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/pubsub/PgSubscriber;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar
         0: .line 623
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 9
         1: .line 625
            aload 0
            ldc "Complex.Channel.Name"
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            invokedynamic handle()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
                  examples/Examples.lambda$50(Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.handler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         2: .line 628
            aload 0
            ldc "Complex.Channel.Name"
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            aload 0
            invokedynamic handle(Lio/reactiverse/pgclient/pubsub/PgSubscriber;)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
                  examples/Examples.lambda$51(Lio/reactiverse/pgclient/pubsub/PgSubscriber;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.subscribeHandler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         3: .line 636
            aload 0
            ldc "simple_channel"
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            invokedynamic handle()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
                  examples/Examples.lambda$53(Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.handler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         4: .line 639
            aload 0
            ldc "simple_channel"
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            aload 0
            invokedynamic handle(Lio/reactiverse/pgclient/pubsub/PgSubscriber;)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
                  examples/Examples.lambda$54(Lio/reactiverse/pgclient/pubsub/PgSubscriber;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.subscribeHandler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         5: .line 649
            aload 0
         6: .line 650
            ldc "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaabbbbb"
         7: .line 649
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
         8: .line 651
            invokedynamic handle()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
                  examples/Examples.lambda$56(Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
            invokeinterface io.reactiverse.pgclient.pubsub.PgChannel.handler:(Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgChannel;
            pop
         9: .line 655
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     1    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static java.lang.Long lambda$57(java.lang.Integer);
    descriptor: (Ljava/lang/Integer;)Ljava/lang/Long;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Integer retries
         0: .line 670
            aload 0 /* retries */
            invokevirtual java.lang.Integer.intValue:()I
            bipush 10
            if_icmpge 2
         1: .line 671
            ldc 100
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            areturn
         2: .line 673
      StackMap locals:
      StackMap stack:
            ldc -1
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            areturn
        end local 0 // java.lang.Integer retries
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0  retries  Ljava/lang/Integer;

  private static void lambda$58(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 690
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifne 2
         1: .line 693
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Could not connect "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 695
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgConnection;>;

  private static void lambda$59(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 738
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 7
         1: .line 739
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rows */
        start local 1 // io.reactiverse.pgclient.PgRowSet rows
         2: .line 740
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Ljava/util/Iterator;
            astore 3
            goto 5
      StackMap locals: io.vertx.core.AsyncResult io.reactiverse.pgclient.PgRowSet top java.util.Iterator
      StackMap stack:
         3: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.Row
            astore 2 /* row */
        start local 2 // io.reactiverse.pgclient.Row row
         4: .line 741
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Full Address "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* row */
            iconst_0
            invokeinterface io.reactiverse.pgclient.Row.getString:(I)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ", City "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* row */
            iconst_1
            invokeinterface io.reactiverse.pgclient.Row.getString:(I)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.reactiverse.pgclient.Row row
         5: .line 740
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
        end local 1 // io.reactiverse.pgclient.PgRowSet rows
         6: .line 743
            goto 8
         7: .line 744
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         8: .line 746
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    6     1  rows  Lio/reactiverse/pgclient/PgRowSet;
            4    5     2   row  Lio/reactiverse/pgclient/Row;

  private static void lambda$60(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 751
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 752
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            astore 1 /* rows */
        start local 1 // io.reactiverse.pgclient.PgRowSet rows
         2: .line 753
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            aload 1 /* rows */
            invokeinterface io.reactiverse.pgclient.PgRowSet.rowCount:()I
            invokevirtual java.io.PrintStream.println:(I)V
        end local 1 // io.reactiverse.pgclient.PgRowSet rows
         3: .line 754
            goto 5
         4: .line 755
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 757
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
            2    3     1  rows  Lio/reactiverse/pgclient/PgRowSet;

  private static java.lang.Long lambda$61(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)Ljava/lang/Long;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.Row row
         0: .line 764
            aload 0 /* row */
            ldc "id"
            invokeinterface io.reactiverse.pgclient.Row.getLong:(Ljava/lang/String;)Ljava/lang/Long;
            areturn
        end local 0 // io.reactiverse.pgclient.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   row  Lio/reactiverse/pgclient/Row;

  private static java.lang.String lambda$62(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)Ljava/lang/String;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.Row row
         0: .line 765
            aload 0 /* row */
            ldc "last_name"
            invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            areturn
        end local 0 // io.reactiverse.pgclient.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   row  Lio/reactiverse/pgclient/Row;

  private static void lambda$63(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 771
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 772
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgResult
            astore 1 /* result */
        start local 1 // io.reactiverse.pgclient.PgResult result
         2: .line 775
            aload 1 /* result */
            invokeinterface io.reactiverse.pgclient.PgResult.value:()Ljava/lang/Object;
            checkcast java.util.Map
            astore 2 /* map */
        start local 2 // java.util.Map map
         3: .line 776
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* map */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // java.util.Map map
        end local 1 // io.reactiverse.pgclient.PgResult result
         4: .line 777
            goto 6
         5: .line 778
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         6: .line 780
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0      ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgResult<Ljava/util/Map<Ljava/lang/Long;Ljava/lang/String;>;>;>;
            2    4     1  result  Lio/reactiverse/pgclient/PgResult<Ljava/util/Map<Ljava/lang/Long;Ljava/lang/String;>;>;
            3    4     2     map  Ljava/util/Map<Ljava/lang/Long;Ljava/lang/String;>;

  private static java.lang.String lambda$64(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)Ljava/lang/String;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.Row row
         0: .line 787
            aload 0 /* row */
            ldc "last_name"
            invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            areturn
        end local 0 // io.reactiverse.pgclient.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   row  Lio/reactiverse/pgclient/Row;

  private static void lambda$65(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 795
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 796
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgResult
            astore 1 /* result */
        start local 1 // io.reactiverse.pgclient.PgResult result
         2: .line 799
            aload 1 /* result */
            invokeinterface io.reactiverse.pgclient.PgResult.value:()Ljava/lang/Object;
            checkcast java.lang.String
            astore 2 /* list */
        start local 2 // java.lang.String list
         3: .line 800
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* list */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // java.lang.String list
        end local 1 // io.reactiverse.pgclient.PgResult result
         4: .line 801
            goto 6
         5: .line 802
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failure: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         6: .line 804
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0      ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgResult<Ljava/lang/String;>;>;
            2    4     1  result  Lio/reactiverse/pgclient/PgResult<Ljava/lang/String;>;
            3    4     2    list  Ljava/lang/String;

  private static void lambda$66(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 809
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 811
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Query success"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 812
            goto 4
         3: .line 814
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Failed to query due to "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 816
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$67(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 818
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 819
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Cancelling request has been sent"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 820
            goto 4
         3: .line 821
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Failed to send cancelling request"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 823
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$4(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar2
         0: .line 157
            aload 1 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 158
            aload 0
            ldc "SELECT * FROM users WHERE id='emad'"
            aload 0
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$5(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         2: .line 162
            goto 4
         3: .line 164
      StackMap locals:
      StackMap stack:
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         4: .line 166
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1   ar2  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$7(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar2
         0: .line 194
            aload 1 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 195
            aload 0
            ldc "SELECT * FROM users WHERE id='emad'"
            aload 0
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$8(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         2: .line 199
            goto 4
         3: .line 201
      StackMap locals:
      StackMap stack:
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         4: .line 203
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1   ar2  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$16(io.vertx.core.AsyncResult, io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar2
         0: .line 339
            aload 0
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 340
            aload 1
            ldc "SELECT * FROM users WHERE id='paulo'"
            aload 1
            invokedynamic handle(Lio/reactiverse/pgclient/PgConnection;)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
                  examples/Examples.lambda$17(Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         2: .line 344
            goto 4
         3: .line 346
      StackMap locals:
      StackMap stack:
            aload 1
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         4: .line 348
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     2   ar2  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$19(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar2
         0: .line 358
            aload 0 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 360
            aload 0 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            pop
         2: .line 362
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0   ar2  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$21(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 380
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 383
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            pop
         2: .line 384
            goto 4
         3: .line 385
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Batch failed "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 387
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0   res  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$23(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 403
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$24(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 404
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$25(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar
         0: .line 408
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 409
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Transaction succeeded"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 410
            goto 4
         3: .line 411
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Transaction failed "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 415
      StackMap locals:
      StackMap stack:
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         5: .line 416
            return
        end local 1 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     1    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$27(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 432
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Transaction failed => rollbacked"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 433
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0     v  Ljava/lang/Void;

  private static void lambda$28(io.reactiverse.pgclient.PgTransaction, io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgTransaction;Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 437
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifne 3
         1: .line 440
            aload 0
            invokeinterface io.reactiverse.pgclient.PgTransaction.rollback:()V
         2: .line 441
            aload 1
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         3: .line 443
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     2    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$29(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 446
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$30(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar
         0: .line 453
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         1: .line 454
            return
        end local 1 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     1    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$32(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 469
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$33(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 470
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$34(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 474
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 475
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Transaction succeeded"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 476
            goto 4
         3: .line 477
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Transaction failed "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 479
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$36(io.reactiverse.pgclient.PgCursor, io.reactiverse.pgclient.PgTransaction, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgCursor;Lio/reactiverse/pgclient/PgTransaction;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar2
         0: .line 497
            aload 2 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 498
            aload 2 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.reactiverse.pgclient.PgRowSet
            pop
         2: .line 501
            aload 0
            invokeinterface io.reactiverse.pgclient.PgCursor.hasMore:()Z
            ifne 4
         3: .line 505
            aload 1
            invokeinterface io.reactiverse.pgclient.PgTransaction.commit:()V
         4: .line 508
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     2   ar2  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$39(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable err
         0: .line 535
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Error: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* err */
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 536
            return
        end local 0 // java.lang.Throwable err
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   err  Ljava/lang/Throwable;

  private static void lambda$40(io.reactiverse.pgclient.PgTransaction, java.lang.Void);
    descriptor: (Lio/reactiverse/pgclient/PgTransaction;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // java.lang.Void v
         0: .line 538
            aload 0
            invokeinterface io.reactiverse.pgclient.PgTransaction.commit:()V
         1: .line 539
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "End of stream"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 540
            return
        end local 1 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     1     v  Ljava/lang/Void;

  private static void lambda$41(io.reactiverse.pgclient.Row);
    descriptor: (Lio/reactiverse/pgclient/Row;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.reactiverse.pgclient.Row row
         0: .line 542
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "User: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* row */
            ldc "last_name"
            invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 543
            return
        end local 0 // io.reactiverse.pgclient.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   row  Lio/reactiverse/pgclient/Row;

  private static void lambda$48(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.String payload
         0: .line 606
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Received "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* payload */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 607
            return
        end local 0 // java.lang.String payload
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  payload  Ljava/lang/String;

  private static void lambda$50(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.String payload
         0: .line 626
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Received "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* payload */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 627
            return
        end local 0 // java.lang.String payload
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  payload  Ljava/lang/String;

  private static void lambda$51(io.reactiverse.pgclient.pubsub.PgSubscriber, java.lang.Void);
    descriptor: (Lio/reactiverse/pgclient/pubsub/PgSubscriber;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // java.lang.Void subscribed
         0: .line 629
            aload 0
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.actualConnection:()Lio/reactiverse/pgclient/PgConnection;
         1: .line 630
            ldc "NOTIFY \"Complex.Channel.Name\", 'msg'"
            invokedynamic handle()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
                  examples/Examples.lambda$52(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
         2: .line 629
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         3: .line 633
            return
        end local 1 // java.lang.Void subscribed
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     1  subscribed  Ljava/lang/Void;

  private static void lambda$53(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.String payload
         0: .line 637
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Received "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* payload */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 638
            return
        end local 0 // java.lang.String payload
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  payload  Ljava/lang/String;

  private static void lambda$54(io.reactiverse.pgclient.pubsub.PgSubscriber, java.lang.Void);
    descriptor: (Lio/reactiverse/pgclient/pubsub/PgSubscriber;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // java.lang.Void subscribed
         0: .line 641
            aload 0
            invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.actualConnection:()Lio/reactiverse/pgclient/PgConnection;
         1: .line 642
            ldc "NOTIFY Simple_CHANNEL, 'msg'"
            invokedynamic handle()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
                  examples/Examples.lambda$55(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
         2: .line 641
            invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
            pop
         3: .line 645
            return
        end local 1 // java.lang.Void subscribed
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     1  subscribed  Ljava/lang/Void;

  private static void lambda$56(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.String payload
         0: .line 652
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Received "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* payload */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 653
            return
        end local 0 // java.lang.String payload
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  payload  Ljava/lang/String;

  private static void lambda$5(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar3
         0: .line 160
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         1: .line 161
            return
        end local 1 // io.vertx.core.AsyncResult ar3
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     1   ar3  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$8(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar3
         0: .line 197
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         1: .line 198
            return
        end local 1 // io.vertx.core.AsyncResult ar3
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     1   ar3  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$17(io.reactiverse.pgclient.PgConnection, io.vertx.core.AsyncResult);
    descriptor: (Lio/reactiverse/pgclient/PgConnection;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar3
         0: .line 342
            aload 0
            invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
         1: .line 343
            return
        end local 1 // io.vertx.core.AsyncResult ar3
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     1   ar3  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$52(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult notified
         0: .line 631
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Notified \"Complex.Channel.Name\""
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 632
            return
        end local 0 // io.vertx.core.AsyncResult notified
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0  notified  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;

  private static void lambda$55(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult notified
         0: .line 643
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Notified simple_channel"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 644
            return
        end local 0 // io.vertx.core.AsyncResult notified
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0  notified  Lio/vertx/core/AsyncResult<Lio/reactiverse/pgclient/PgRowSet;>;
}
SourceFile: "Examples.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
    RuntimeInvisibleAnnotations: 
      io.vertx.docgen.Source()