public class examples.RxExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.RxExamples
  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.RxExamples this
         0: .line 29
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.RxExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/RxExamples;

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

  public void streamingQuery01Example(io.reactiverse.reactivex.pgclient.PgPool);
    descriptor: (Lio/reactiverse/reactivex/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxExamples this
        start local 1 // io.reactiverse.reactivex.pgclient.PgPool pool
         0: .line 47
            aload 1 /* pool */
            invokevirtual io.reactiverse.reactivex.pgclient.PgPool.rxBegin:()Lio/reactivex/Single;
         1: .line 48
            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/RxExamples.lambda$2(Lio/reactiverse/reactivex/pgclient/PgTransaction;)Lio/reactivex/ObservableSource; (6)
                  (Lio/reactiverse/reactivex/pgclient/PgTransaction;)Lio/reactivex/ObservableSource;
            invokevirtual io.reactivex.Single.flatMapObservable:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
         2: .line 47
            astore 2 /* observable */
        start local 2 // io.reactivex.Observable observable
         3: .line 59
            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/RxExamples.lambda$5(Lio/reactiverse/reactivex/pgclient/Row;)V (6)
                  (Lio/reactiverse/reactivex/pgclient/Row;)V
         4: .line 61
            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/RxExamples.lambda$6(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         5: .line 63
            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/RxExamples.lambda$7()V (6)
                  ()V
         6: .line 59
            invokevirtual io.reactivex.Observable.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
            pop
         7: .line 66
            return
        end local 2 // io.reactivex.Observable observable
        end local 1 // io.reactiverse.reactivex.pgclient.PgPool pool
        end local 0 // examples.RxExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    8     0        this  Lexamples/RxExamples;
            0    8     1        pool  Lio/reactiverse/reactivex/pgclient/PgPool;
            3    8     2  observable  Lio/reactivex/Observable<Lio/reactiverse/reactivex/pgclient/Row;>;
    MethodParameters:
      Name  Flags
      pool  

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

  public void transaction01Example(io.reactiverse.reactivex.pgclient.PgPool);
    descriptor: (Lio/reactiverse/reactivex/pgclient/PgPool;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.RxExamples this
        start local 1 // io.reactiverse.reactivex.pgclient.PgPool pool
         0: .line 112
            aload 1 /* pool */
         1: .line 113
            invokevirtual io.reactiverse.reactivex.pgclient.PgPool.rxBegin:()Lio/reactivex/Single;
         2: .line 114
            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/RxExamples.lambda$11(Lio/reactiverse/reactivex/pgclient/PgTransaction;)Lio/reactivex/CompletableSource; (6)
                  (Lio/reactiverse/reactivex/pgclient/PgTransaction;)Lio/reactivex/CompletableSource;
            invokevirtual io.reactivex.Single.flatMapCompletable:(Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
         3: .line 112
            astore 2 /* completable */
        start local 2 // io.reactivex.Completable completable
         4: .line 119
            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/RxExamples.lambda$14()V (6)
                  ()V
         5: .line 121
            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/RxExamples.lambda$15(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         6: .line 119
            invokevirtual io.reactivex.Completable.subscribe:(Lio/reactivex/functions/Action;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
            pop
         7: .line 124
            return
        end local 2 // io.reactivex.Completable completable
        end local 1 // io.reactiverse.reactivex.pgclient.PgPool pool
        end local 0 // examples.RxExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0         this  Lexamples/RxExamples;
            0    8     1         pool  Lio/reactiverse/reactivex/pgclient/PgPool;
            4    8     2  completable  Lio/reactivex/Completable;
    MethodParameters:
      Name  Flags
      pool  

  private static void lambda$0(io.reactiverse.reactivex.pgclient.PgRowSet);
    descriptor: (Lio/reactiverse/reactivex/pgclient/PgRowSet;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.reactiverse.reactivex.pgclient.PgRowSet result
         0: .line 38
            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.reactiverse.reactivex.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
         1: .line 39
            return
        end local 0 // io.reactiverse.reactivex.pgclient.PgRowSet result
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  result  Lio/reactiverse/reactivex/pgclient/PgRowSet;
    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 40
            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 41
            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.reactiverse.reactivex.pgclient.PgTransaction);
    descriptor: (Lio/reactiverse/reactivex/pgclient/PgTransaction;)Lio/reactivex/ObservableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.reactiverse.reactivex.pgclient.PgTransaction tx
         0: .line 48
            aload 0 /* tx */
         1: .line 49
            ldc "SELECT * FROM users WHERE first_name LIKE $1"
            invokevirtual io.reactiverse.reactivex.pgclient.PgTransaction.rxPrepare:(Ljava/lang/String;)Lio/reactivex/Single;
         2: .line 50
            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/RxExamples.lambda$3(Lio/reactiverse/reactivex/pgclient/PgPreparedQuery;)Lio/reactivex/ObservableSource; (6)
                  (Lio/reactiverse/reactivex/pgclient/PgPreparedQuery;)Lio/reactivex/ObservableSource;
            invokevirtual io.reactivex.Single.flatMapObservable:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
         3: .line 56
            aload 0 /* tx */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic run(Lio/reactiverse/reactivex/pgclient/PgTransaction;)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/reactiverse/reactivex/pgclient/PgTransaction.commit()V (5)
                  ()V
            invokevirtual io.reactivex.Observable.doAfterTerminate:(Lio/reactivex/functions/Action;)Lio/reactivex/Observable;
            areturn
        end local 0 // io.reactiverse.reactivex.pgclient.PgTransaction tx
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0    tx  Lio/reactiverse/reactivex/pgclient/PgTransaction;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$5(io.reactiverse.reactivex.pgclient.Row);
    descriptor: (Lio/reactiverse/reactivex/pgclient/Row;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.reactiverse.reactivex.pgclient.Row row
         0: .line 60
            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.reactiverse.reactivex.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 61
            return
        end local 0 // io.reactiverse.reactivex.pgclient.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0   row  Lio/reactiverse/reactivex/pgclient/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 62
            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 63
            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 64
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "End of stream"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 65
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception

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

  private static io.reactivex.CompletableSource lambda$11(io.reactiverse.reactivex.pgclient.PgTransaction);
    descriptor: (Lio/reactiverse/reactivex/pgclient/PgTransaction;)Lio/reactivex/CompletableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactiverse.reactivex.pgclient.PgTransaction tx
         0: .line 114
            aload 0 /* tx */
         1: .line 115
            ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
            invokevirtual io.reactiverse.reactivex.pgclient.PgTransaction.rxQuery:(Ljava/lang/String;)Lio/reactivex/Single;
         2: .line 116
            aload 0 /* tx */
            invokedynamic apply(Lio/reactiverse/reactivex/pgclient/PgTransaction;)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/RxExamples.lambda$12(Lio/reactiverse/reactivex/pgclient/PgTransaction;Lio/reactiverse/reactivex/pgclient/PgRowSet;)Lio/reactivex/SingleSource; (6)
                  (Lio/reactiverse/reactivex/pgclient/PgRowSet;)Lio/reactivex/SingleSource;
            invokevirtual io.reactivex.Single.flatMap:(Lio/reactivex/functions/Function;)Lio/reactivex/Single;
         3: .line 117
            aload 0 /* tx */
            invokedynamic apply(Lio/reactiverse/reactivex/pgclient/PgTransaction;)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/RxExamples.lambda$13(Lio/reactiverse/reactivex/pgclient/PgTransaction;Lio/reactiverse/reactivex/pgclient/PgRowSet;)Lio/reactivex/CompletableSource; (6)
                  (Lio/reactiverse/reactivex/pgclient/PgRowSet;)Lio/reactivex/CompletableSource;
            invokevirtual io.reactivex.Single.flatMapCompletable:(Lio/reactivex/functions/Function;)Lio/reactivex/Completable;
            areturn
        end local 0 // io.reactiverse.reactivex.pgclient.PgTransaction tx
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0    tx  Lio/reactiverse/reactivex/pgclient/PgTransaction;
    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 121
            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 123
            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.reactiverse.reactivex.pgclient.PgPreparedQuery);
    descriptor: (Lio/reactiverse/reactivex/pgclient/PgPreparedQuery;)Lio/reactivex/ObservableSource;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.reactiverse.reactivex.pgclient.PgPreparedQuery preparedQuery
         0: .line 52
            aload 0 /* preparedQuery */
            bipush 50
            ldc "julien"
            invokestatic io.reactiverse.reactivex.pgclient.Tuple.of:(Ljava/lang/Object;)Lio/reactiverse/reactivex/pgclient/Tuple;
            invokevirtual io.reactiverse.reactivex.pgclient.PgPreparedQuery.createStream:(ILio/reactiverse/reactivex/pgclient/Tuple;)Lio/reactiverse/reactivex/pgclient/PgStream;
            astore 1 /* stream */
        start local 1 // io.reactiverse.reactivex.pgclient.PgStream stream
         1: .line 53
            aload 1 /* stream */
            invokevirtual io.reactiverse.reactivex.pgclient.PgStream.toObservable:()Lio/reactivex/Observable;
            areturn
        end local 1 // io.reactiverse.reactivex.pgclient.PgStream stream
        end local 0 // io.reactiverse.reactivex.pgclient.PgPreparedQuery preparedQuery
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0  preparedQuery  Lio/reactiverse/reactivex/pgclient/PgPreparedQuery;
            1    2     1         stream  Lio/reactiverse/reactivex/pgclient/PgStream<Lio/reactiverse/reactivex/pgclient/Row;>;
    Exceptions:
      throws java.lang.Exception

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

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

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