http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-rx/vertx-rx-java2: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class examples.RxPgClientExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.RxPgClientExamples
  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.RxPgClientExamples this
         0: .line 14
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.RxPgClientExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/RxPgClientExamples;

  public void simpleQuery01Example(io.vertx.reactivex.pgclient.PgPool);
    descriptor: (Lio/vertx/reactivex/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.RxPgClientExamples this
        start local 1 // io.vertx.reactivex.pgclient.PgPool pool
         0: .line 19
            aload 1 /* pool */
            ldc "SELECT * FROM users WHERE id='julien'"
            invokevirtual io.vertx.reactivex.pgclient.PgPool.rxQuery:(Ljava/lang/String;)Lio/reactivex/Single;
            astore 2 /* single */
        start local 2 // io.reactivex.Single single
         1: .line 22
            aload 2 /* single */
            invokedynamic accept()Lio/reactivex/functions/Consumer;
              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/RxPgClientExamples.lambda$0(Lio/vertx/reactivex/sqlclient/RowSet;)V (6)
                  (Lio/vertx/reactivex/sqlclient/RowSet;)V
         2: .line 24
            invokedynamic accept()Lio/reactivex/functions/Consumer;
              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/RxPgClientExamples.lambda$1(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         3: .line 22
            invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
            pop
         4: .line 27
            return
        end local 2 // io.reactivex.Single single
        end local 1 // io.vertx.reactivex.pgclient.PgPool pool
        end local 0 // examples.RxPgClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lexamples/RxPgClientExamples;
            0    5     1    pool  Lio/vertx/reactivex/pgclient/PgPool;
            1    5     2  single  Lio/reactivex/Single<Lio/vertx/reactivex/sqlclient/RowSet;>;
    MethodParameters:
      Name  Flags
      pool  

  public void streamingQuery01Example(io.vertx.reactivex.pgclient.PgPool);
    descriptor: (Lio/vertx/reactivex/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxPgClientExamples this
        start local 1 // io.vertx.reactivex.pgclient.PgPool pool
         0: .line 32
            aload 1 /* pool */
            invokevirtual io.vertx.reactivex.pgclient.PgPool.rxBegin:()Lio/reactivex/Single;
         1: .line 33
            invokedynamic apply()Lio/reactivex/functions/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/RxPgClientExamples.lambda$2(Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/ObservableSource; (6)
                  (Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/ObservableSource;
            invokevirtual io.reactivex.Single.flatMapObservable:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
         2: .line 32
            astore 2 /* observable */
        start local 2 // io.reactivex.Observable observable
         3: .line 44
            aload 2 /* observable */
            invokedynamic accept()Lio/reactivex/functions/Consumer;
              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/RxPgClientExamples.lambda$5(Lio/vertx/reactivex/sqlclient/Row;)V (6)
                  (Lio/vertx/reactivex/sqlclient/Row;)V
         4: .line 46
            invokedynamic accept()Lio/reactivex/functions/Consumer;
              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/RxPgClientExamples.lambda$6(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         5: .line 48
            invokedynamic run()Lio/reactivex/functions/Action;
              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:
                  ()V
                  examples/RxPgClientExamples.lambda$7()V (6)
                  ()V
         6: .line 44
            invokevirtual io.reactivex.Observable.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
            pop
         7: .line 51
            return
        end local 2 // io.reactivex.Observable observable
        end local 1 // io.vertx.reactivex.pgclient.PgPool pool
        end local 0 // examples.RxPgClientExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    8     0        this  Lexamples/RxPgClientExamples;
            0    8     1        pool  Lio/vertx/reactivex/pgclient/PgPool;
            3    8     2  observable  Lio/reactivex/Observable<Lio/vertx/reactivex/sqlclient/Row;>;
    MethodParameters:
      Name  Flags
      pool  

  public void streamingQuery02Example(io.vertx.reactivex.pgclient.PgPool);
    descriptor: (Lio/vertx/reactivex/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxPgClientExamples this
        start local 1 // io.vertx.reactivex.pgclient.PgPool pool
         0: .line 56
            aload 1 /* pool */
            invokevirtual io.vertx.reactivex.pgclient.PgPool.rxBegin:()Lio/reactivex/Single;
         1: .line 57
            invokedynamic apply()Lio/reactivex/functions/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/RxPgClientExamples.lambda$8(Lio/vertx/reactivex/sqlclient/Transaction;)Lorg/reactivestreams/Publisher; (6)
                  (Lio/vertx/reactivex/sqlclient/Transaction;)Lorg/reactivestreams/Publisher;
            invokevirtual io.reactivex.Single.flatMapPublisher:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
         2: .line 56
            astore 2 /* flowable */
        start local 2 // io.reactivex.Flowable flowable
         3: .line 67
            aload 2 /* flowable */
            new examples.RxPgClientExamples$1
            dup
            aload 0 /* this */
            invokespecial examples.RxPgClientExamples$1.<init>:(Lexamples/RxPgClientExamples;)V
            invokevirtual io.reactivex.Flowable.subscribe:(Lorg/reactivestreams/Subscriber;)V
         4: .line 93
            return
        end local 2 // io.reactivex.Flowable flowable
        end local 1 // io.vertx.reactivex.pgclient.PgPool pool
        end local 0 // examples.RxPgClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lexamples/RxPgClientExamples;
            0    5     1      pool  Lio/vertx/reactivex/pgclient/PgPool;
            3    5     2  flowable  Lio/reactivex/Flowable<Lio/vertx/reactivex/sqlclient/Row;>;
    MethodParameters:
      Name  Flags
      pool  

  public void transaction01Example(io.vertx.reactivex.pgclient.PgPool);
    descriptor: (Lio/vertx/reactivex/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.RxPgClientExamples this
        start local 1 // io.vertx.reactivex.pgclient.PgPool pool
         0: .line 97
            aload 1 /* pool */
         1: .line 98
            invokevirtual io.vertx.reactivex.pgclient.PgPool.rxBegin:()Lio/reactivex/Single;
         2: .line 99
            invokedynamic apply()Lio/reactivex/functions/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/RxPgClientExamples.lambda$11(Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/CompletableSource; (6)
                  (Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/CompletableSource;
            invokevirtual io.reactivex.Single.flatMapCompletable:(Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
         3: .line 97
            astore 2 /* completable */
        start local 2 // io.reactivex.Completable completable
         4: .line 104
            aload 2 /* completable */
            invokedynamic run()Lio/reactivex/functions/Action;
              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:
                  ()V
                  examples/RxPgClientExamples.lambda$14()V (6)
                  ()V
         5: .line 106
            invokedynamic accept()Lio/reactivex/functions/Consumer;
              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/RxPgClientExamples.lambda$15(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         6: .line 104
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
            pop
         7: .line 109
            return
        end local 2 // io.reactivex.Completable completable
        end local 1 // io.vertx.reactivex.pgclient.PgPool pool
        end local 0 // examples.RxPgClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0         this  Lexamples/RxPgClientExamples;
            0    8     1         pool  Lio/vertx/reactivex/pgclient/PgPool;
            4    8     2  completable  Lio/reactivex/Completable;
    MethodParameters:
      Name  Flags
      pool  

  private static void lambda$0(io.vertx.reactivex.sqlclient.RowSet);
    descriptor: (Lio/vertx/reactivex/sqlclient/RowSet;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.RowSet result
         0: .line 23
            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 0 /* result */
            invokevirtual io.vertx.reactivex.sqlclient.RowSet.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
         1: .line 24
            return
        end local 0 // io.vertx.reactivex.sqlclient.RowSet result
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  result  Lio/vertx/reactivex/sqlclient/RowSet;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$1(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 25
            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 /* 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 26
            return
        end local 0 // java.lang.Throwable err
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   err  Ljava/lang/Throwable;
    Exceptions:
      throws java.lang.Exception

  private static io.reactivex.ObservableSource lambda$2(io.vertx.reactivex.sqlclient.Transaction);
    descriptor: (Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/ObservableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.Transaction tx
         0: .line 33
            aload 0 /* tx */
         1: .line 34
            ldc "SELECT * FROM users WHERE first_name LIKE $1"
            invokevirtual io.vertx.reactivex.sqlclient.Transaction.rxPrepare:(Ljava/lang/String;)Lio/reactivex/Single;
         2: .line 35
            invokedynamic apply()Lio/reactivex/functions/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/RxPgClientExamples.lambda$3(Lio/vertx/reactivex/sqlclient/PreparedQuery;)Lio/reactivex/ObservableSource; (6)
                  (Lio/vertx/reactivex/sqlclient/PreparedQuery;)Lio/reactivex/ObservableSource;
            invokevirtual io.reactivex.Single.flatMapObservable:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
         3: .line 41
            aload 0 /* tx */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic run(Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/functions/Action;
              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:
                  ()V
                  io/vertx/reactivex/sqlclient/Transaction.commit()V (5)
                  ()V
            invokevirtual io.reactivex.Observable.doAfterTerminate:(Lio/reactivex/functions/Action;)Lio/reactivex/Observable;
            areturn
        end local 0 // io.vertx.reactivex.sqlclient.Transaction tx
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0    tx  Lio/vertx/reactivex/sqlclient/Transaction;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$5(io.vertx.reactivex.sqlclient.Row);
    descriptor: (Lio/vertx/reactivex/sqlclient/Row;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.Row row
         0: .line 45
            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"
            invokevirtual io.vertx.reactivex.sqlclient.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 46
            return
        end local 0 // io.vertx.reactivex.sqlclient.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   row  Lio/vertx/reactivex/sqlclient/Row;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$6(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 47
            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 48
            return
        end local 0 // java.lang.Throwable err
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   err  Ljava/lang/Throwable;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$7();
    descriptor: ()V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 49
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "End of stream"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 50
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception

  private static org.reactivestreams.Publisher lambda$8(io.vertx.reactivex.sqlclient.Transaction);
    descriptor: (Lio/vertx/reactivex/sqlclient/Transaction;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.Transaction tx
         0: .line 57
            aload 0 /* tx */
            ldc "SELECT * FROM users WHERE first_name LIKE $1"
            invokevirtual io.vertx.reactivex.sqlclient.Transaction.rxPrepare:(Ljava/lang/String;)Lio/reactivex/Single;
         1: .line 58
            invokedynamic apply()Lio/reactivex/functions/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/RxPgClientExamples.lambda$9(Lio/vertx/reactivex/sqlclient/PreparedQuery;)Lorg/reactivestreams/Publisher; (6)
                  (Lio/vertx/reactivex/sqlclient/PreparedQuery;)Lorg/reactivestreams/Publisher;
            invokevirtual io.reactivex.Single.flatMapPublisher:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
         2: .line 64
            aload 0 /* tx */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic run(Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/functions/Action;
              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:
                  ()V
                  io/vertx/reactivex/sqlclient/Transaction.commit()V (5)
                  ()V
            invokevirtual io.reactivex.Flowable.doAfterTerminate:(Lio/reactivex/functions/Action;)Lio/reactivex/Flowable;
            areturn
        end local 0 // io.vertx.reactivex.sqlclient.Transaction tx
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0    tx  Lio/vertx/reactivex/sqlclient/Transaction;
    Exceptions:
      throws java.lang.Exception

  private static io.reactivex.CompletableSource lambda$11(io.vertx.reactivex.sqlclient.Transaction);
    descriptor: (Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/CompletableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.Transaction tx
         0: .line 99
            aload 0 /* tx */
         1: .line 100
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
            invokevirtual io.vertx.reactivex.sqlclient.Transaction.rxQuery:(Ljava/lang/String;)Lio/reactivex/Single;
         2: .line 101
            aload 0 /* tx */
            invokedynamic apply(Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/functions/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/RxPgClientExamples.lambda$12(Lio/vertx/reactivex/sqlclient/Transaction;Lio/vertx/reactivex/sqlclient/RowSet;)Lio/reactivex/SingleSource; (6)
                  (Lio/vertx/reactivex/sqlclient/RowSet;)Lio/reactivex/SingleSource;
            invokevirtual io.reactivex.Single.flatMap:(Lio/reactivex/functions/Function;)Lio/reactivex/Single;
         3: .line 102
            aload 0 /* tx */
            invokedynamic apply(Lio/vertx/reactivex/sqlclient/Transaction;)Lio/reactivex/functions/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/RxPgClientExamples.lambda$13(Lio/vertx/reactivex/sqlclient/Transaction;Lio/vertx/reactivex/sqlclient/RowSet;)Lio/reactivex/CompletableSource; (6)
                  (Lio/vertx/reactivex/sqlclient/RowSet;)Lio/reactivex/CompletableSource;
            invokevirtual io.reactivex.Single.flatMapCompletable:(Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.vertx.reactivex.sqlclient.Transaction tx
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0    tx  Lio/vertx/reactivex/sqlclient/Transaction;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$14();
    descriptor: ()V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=0, args_size=0
         0: .line 106
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception

  private static void lambda$15(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Throwable err
         0: .line 108
            return
        end local 0 // java.lang.Throwable err
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   err  Ljava/lang/Throwable;
    Exceptions:
      throws java.lang.Exception

  private static io.reactivex.ObservableSource lambda$3(io.vertx.reactivex.sqlclient.PreparedQuery);
    descriptor: (Lio/vertx/reactivex/sqlclient/PreparedQuery;)Lio/reactivex/ObservableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.PreparedQuery preparedQuery
         0: .line 37
            aload 0 /* preparedQuery */
            bipush 50
            ldc "julien"
            invokestatic io.vertx.reactivex.sqlclient.Tuple.of:(Ljava/lang/Object;)Lio/vertx/reactivex/sqlclient/Tuple;
            invokevirtual io.vertx.reactivex.sqlclient.PreparedQuery.createStream:(ILio/vertx/reactivex/sqlclient/Tuple;)Lio/vertx/reactivex/sqlclient/RowStream;
            astore 1 /* stream */
        start local 1 // io.vertx.reactivex.sqlclient.RowStream stream
         1: .line 38
            aload 1 /* stream */
            invokevirtual io.vertx.reactivex.sqlclient.RowStream.toObservable:()Lio/reactivex/Observable;
            areturn
        end local 1 // io.vertx.reactivex.sqlclient.RowStream stream
        end local 0 // io.vertx.reactivex.sqlclient.PreparedQuery preparedQuery
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0  preparedQuery  Lio/vertx/reactivex/sqlclient/PreparedQuery;
            1    2     1         stream  Lio/vertx/reactivex/sqlclient/RowStream<Lio/vertx/reactivex/sqlclient/Row;>;
    Exceptions:
      throws java.lang.Exception

  private static org.reactivestreams.Publisher lambda$9(io.vertx.reactivex.sqlclient.PreparedQuery);
    descriptor: (Lio/vertx/reactivex/sqlclient/PreparedQuery;)Lorg/reactivestreams/Publisher;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.reactivex.sqlclient.PreparedQuery preparedQuery
         0: .line 60
            aload 0 /* preparedQuery */
            bipush 50
            ldc "julien"
            invokestatic io.vertx.reactivex.sqlclient.Tuple.of:(Ljava/lang/Object;)Lio/vertx/reactivex/sqlclient/Tuple;
            invokevirtual io.vertx.reactivex.sqlclient.PreparedQuery.createStream:(ILio/vertx/reactivex/sqlclient/Tuple;)Lio/vertx/reactivex/sqlclient/RowStream;
            astore 1 /* stream */
        start local 1 // io.vertx.reactivex.sqlclient.RowStream stream
         1: .line 61
            aload 1 /* stream */
            invokevirtual io.vertx.reactivex.sqlclient.RowStream.toFlowable:()Lio/reactivex/Flowable;
            areturn
        end local 1 // io.vertx.reactivex.sqlclient.RowStream stream
        end local 0 // io.vertx.reactivex.sqlclient.PreparedQuery preparedQuery
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0  preparedQuery  Lio/vertx/reactivex/sqlclient/PreparedQuery;
            1    2     1         stream  Lio/vertx/reactivex/sqlclient/RowStream<Lio/vertx/reactivex/sqlclient/Row;>;
    Exceptions:
      throws java.lang.Exception

  private static io.reactivex.SingleSource lambda$12(io.vertx.reactivex.sqlclient.Transaction, io.vertx.reactivex.sqlclient.RowSet);
    descriptor: (Lio/vertx/reactivex/sqlclient/Transaction;Lio/vertx/reactivex/sqlclient/RowSet;)Lio/reactivex/SingleSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.reactivex.sqlclient.RowSet result
         0: .line 101
            aload 0
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Emad','Alblueshi')"
            invokevirtual io.vertx.reactivex.sqlclient.Transaction.rxQuery:(Ljava/lang/String;)Lio/reactivex/Single;
            areturn
        end local 1 // io.vertx.reactivex.sqlclient.RowSet result
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     1  result  Lio/vertx/reactivex/sqlclient/RowSet;
    Exceptions:
      throws java.lang.Exception

  private static io.reactivex.CompletableSource lambda$13(io.vertx.reactivex.sqlclient.Transaction, io.vertx.reactivex.sqlclient.RowSet);
    descriptor: (Lio/vertx/reactivex/sqlclient/Transaction;Lio/vertx/reactivex/sqlclient/RowSet;)Lio/reactivex/CompletableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // io.vertx.reactivex.sqlclient.RowSet result
         0: .line 102
            aload 0
            invokevirtual io.vertx.reactivex.sqlclient.Transaction.rxCommit:()Lio/reactivex/Completable;
            areturn
        end local 1 // io.vertx.reactivex.sqlclient.RowSet result
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     1  result  Lio/vertx/reactivex/sqlclient/RowSet;
    Exceptions:
      throws java.lang.Exception
}
SourceFile: "RxPgClientExamples.java"
NestMembers:
  examples.RxPgClientExamples$1
InnerClasses:
  examples.RxPgClientExamples$1
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
    RuntimeInvisibleAnnotations: 
      io.vertx.docgen.Source()