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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 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 0: new io.reactiverse.pgclient.PgPoolOptions
dup
invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
6: iconst_5
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
7: astore 1
start local 1 8: aload 1
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
astore 2
start local 2 9: aload 2
ldc "SELECT * FROM users WHERE id='julien'"
aload 2
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: return
end local 2 end local 1 end local 0 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 start local 1 0: invokestatic io.reactiverse.pgclient.PgClient.pool:()Lio/reactiverse/pgclient/PgPool;
pop
1: aload 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$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: return
end local 1 end local 0 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 start local 1 0: ldc "postgresql://dbuser:secretpassword@database.server.com:3211/mydb"
astore 2
start local 2 1: aload 2
invokestatic io.reactiverse.pgclient.PgClient.pool:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPool;
pop
2: aload 1
aload 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$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: return
end local 2 end local 1 end local 0 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 0: new io.reactiverse.pgclient.PgPoolOptions
dup
invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
6: iconst_5
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
7: astore 1
start local 1 8: aload 1
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
pop
9: return
end local 1 end local 0 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 start local 1 0: new io.reactiverse.pgclient.PgPoolOptions
dup
invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
6: iconst_5
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
7: astore 2
start local 2 8: aload 1
aload 2
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
pop
9: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
invokeinterface io.reactiverse.pgclient.PgPool.close:()V
1: return
end local 1 end local 0 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 start local 1 0: new io.reactiverse.pgclient.PgPoolOptions
dup
invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
6: iconst_5
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setMaxSize:(I)Lio/reactiverse/pgclient/PgPoolOptions;
7: astore 2
start local 2 8: aload 1
aload 2
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
astore 3
start local 3 9: aload 3
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: return
end local 3 end local 2 end local 1 end local 0 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 start local 1 0: new io.reactiverse.pgclient.PgConnectOptions
dup
invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
6: astore 2
start local 2 7: aload 1
aload 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$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: return
end local 2 end local 1 end local 0 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 start local 1 0: new io.reactiverse.pgclient.PgPoolOptions
dup
invokespecial io.reactiverse.pgclient.PgPoolOptions.<init>:()V
1: ldc "/var/run/postgresql"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
2: sipush 5432
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setPort:(I)Lio/reactiverse/pgclient/PgPoolOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgPoolOptions;
4: astore 2
start local 2 5: aload 2
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
pop
6: aload 1
aload 2
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
pop
7: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: 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
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
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: return
end local 1 end local 0 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 start local 1 0: 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
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
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: return
end local 1 end local 0 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 start local 1 0: aload 1
ldc "first_name"
invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
pop
1: aload 1
ldc "male"
invokeinterface io.reactiverse.pgclient.Row.getBoolean:(Ljava/lang/String;)Ljava/lang/Boolean;
pop
2: aload 1
ldc "age"
invokeinterface io.reactiverse.pgclient.Row.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
pop
3: return
end local 1 end local 0 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 start local 1 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 1: aload 2
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: aload 2
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: aload 1
ldc "INSERT INTO USERS (id, name) VALUES ($1, $2)"
aload 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$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: return
end local 2 end local 1 end local 0 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 start local 1 start local 2 0: aload 2
iconst_1
invokevirtual io.reactiverse.pgclient.PgPoolOptions.setCachePreparedStatements:(Z)Lio/reactiverse/pgclient/PgPoolOptions;
pop
1: aload 1
aload 2
invokestatic io.reactiverse.pgclient.PgClient.pool:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgPoolOptions;)Lio/reactiverse/pgclient/PgPool;
pop
2: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 start local 2 0: aload 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$15(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 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$22(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 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 start local 1 0: aload 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$26(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.reactiverse.pgclient.PgPool.getConnection:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 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 start local 1 0: aload 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$31(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.reactiverse.pgclient.PgPool.begin:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 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 start local 1 0: aload 1
ldc "SELECT * FROM users WHERE first_name LIKE $1"
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$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: return
end local 1 end local 0 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 start local 1 0: aload 1
bipush 50
aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
ldc "SELECT * FROM users WHERE first_name LIKE $1"
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$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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 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$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: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
new io.reactiverse.pgclient.PgConnectOptions
dup
invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
6: invokestatic io.reactiverse.pgclient.pubsub.PgSubscriber.subscriber:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
astore 2
start local 2 7: aload 2
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: aload 2
aload 2
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: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
new io.reactiverse.pgclient.PgConnectOptions
dup
invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
6: invokestatic io.reactiverse.pgclient.pubsub.PgSubscriber.subscriber:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
astore 2
start local 2 7: aload 2
aload 2
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: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
new io.reactiverse.pgclient.PgConnectOptions
dup
invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
6: invokestatic io.reactiverse.pgclient.pubsub.PgSubscriber.subscriber:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
astore 2
start local 2 7: aload 2
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: return
end local 2 end local 1 end local 0 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 start local 1 0: new io.reactiverse.pgclient.PgConnectOptions
dup
invokespecial io.reactiverse.pgclient.PgConnectOptions.<init>:()V
1: sipush 5432
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPort:(I)Lio/reactiverse/pgclient/PgConnectOptions;
2: ldc "the-host"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setHost:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
3: ldc "the-db"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setDatabase:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
4: ldc "user"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setUser:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
5: ldc "secret"
invokevirtual io.reactiverse.pgclient.PgConnectOptions.setPassword:(Ljava/lang/String;)Lio/reactiverse/pgclient/PgConnectOptions;
6: 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: 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: astore 2
start local 2 9: aload 1
aload 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$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: return
end local 2 end local 1 end local 0 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 0: 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: 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: 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: invokestatic io.reactiverse.pgclient.Tuple.of:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lio/reactiverse/pgclient/Tuple;
astore 1
start local 1 4: aload 1
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: aload 1
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: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
ldc "value"
invokeinterface io.reactiverse.pgclient.Row.getNumeric:(Ljava/lang/String;)Lio/reactiverse/pgclient/data/Numeric;
astore 2
start local 2 1: aload 2
invokevirtual io.reactiverse.pgclient.data.Numeric.isNaN:()Z
ifne 3
2: aload 2
invokevirtual io.reactiverse.pgclient.data.Numeric.bigDecimalValue:()Ljava/math/BigDecimal;
pop
3: StackMap locals: io.reactiverse.pgclient.data.Numeric
StackMap stack:
return
end local 2 end local 1 end local 0 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 0: 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
start local 1 1: aload 1
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: aload 1
iconst_0
invokeinterface io.reactiverse.pgclient.Tuple.getStringArray:(I)[Ljava/lang/String;
pop
3: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: aload 1
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: return
end local 1 end local 0 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 start local 1 0: 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: 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: invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
astore 2
start local 2 3: aload 1
ldc "SELECT * FROM users"
4: aload 2
5: 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: invokeinterface io.reactiverse.pgclient.PgClient.query:(Ljava/lang/String;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
pop
7: return
end local 2 end local 1 end local 0 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 start local 1 0: 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: ldc ","
ldc "("
ldc ")"
invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
2: invokestatic java.util.stream.Collectors.mapping:(Ljava/util/function/Function;Ljava/util/stream/Collector;)Ljava/util/stream/Collector;
astore 2
start local 2 3: aload 1
ldc "SELECT * FROM users"
4: aload 2
5: 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: invokeinterface io.reactiverse.pgclient.PgClient.query:(Ljava/lang/String;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgClient;
pop
7: return
end local 2 end local 1 end local 0 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 start local 1 0: aload 1
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: aload 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$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: return
end local 1 end local 0 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 1
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 2
start local 2 2: 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
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 3: goto 5
4: 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
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: StackMap locals:
StackMap stack:
aload 0
invokeinterface io.reactiverse.pgclient.PgPool.close:()V
6: return
end local 1 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 0: return
end local 0 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 0: return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Connected"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgConnection
astore 1
start local 1 3: aload 1
ldc "SELECT * FROM users WHERE id='julien'"
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$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 4: goto 6
5: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Connected"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgConnection
astore 1
start local 1 3: aload 1
ldc "SELECT * FROM users WHERE id='julien'"
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$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 4: goto 6
5: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: 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
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 3: goto 5
4: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: 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
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 3: goto 5
4: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 7
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: aload 1
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
start local 2 4: 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
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
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 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
end local 1 6: goto 8
7: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
aload 1
invokeinterface io.reactiverse.pgclient.PgRowSet.rowCount:()I
invokevirtual java.io.PrintStream.println:(I)V
end local 1 3: goto 5
4: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
pop
2: goto 4
3: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 8
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
aload 1
invokeinterface io.reactiverse.pgclient.PgRowSet.rowCount:()I
invokevirtual java.io.PrintStream.println:(I)V
3: aload 1
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
start local 2 5: 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
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 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
end local 1 7: goto 9
8: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgConnection
astore 1
start local 1 2: aload 1
ldc "SELECT * FROM users WHERE id='julien'"
aload 0
aload 1
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 3: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgPreparedQuery
astore 1
start local 1 2: aload 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$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 3: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 6
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgPreparedQuery
astore 1
start local 1 2: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 3: aload 2
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: aload 2
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: aload 1
aload 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$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 end local 1 6: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 6
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgConnection
astore 1
start local 1 2: aload 1
invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
astore 2
start local 2 3: aload 1
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: aload 1
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: aload 2
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$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 end local 1 6: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 9
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgConnection
astore 1
start local 1 2: aload 1
3: invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
4: 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: astore 2
start local 2 6: aload 1
ldc "INSERT INTO Users (first_name,last_name) VALUES ('Julien','Viet')"
aload 2
aload 1
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: aload 1
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: aload 2
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$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 end local 1 9: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgTransaction
astore 1
start local 1 2: aload 1
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: aload 1
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: aload 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$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 5: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 1
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgPreparedQuery
astore 2
start local 2 2: aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
astore 3
start local 3 3: aload 2
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
start local 4 4: aload 4
bipush 50
aload 4
aload 3
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 end local 3 end local 2 5: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 2
1: aload 0
invokeinterface io.reactiverse.pgclient.PgCursor.close:()V
2: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 7
1: aload 1
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgPreparedQuery
astore 2
start local 2 2: aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.begin:()Lio/reactiverse/pgclient/PgTransaction;
astore 3
start local 3 3: aload 2
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
start local 4 4: aload 4
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: aload 4
aload 3
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: aload 4
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 end local 3 end local 2 7: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 1: aload 1
invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Lio/reactiverse/pgclient/PgIterator;
invokeinterface io.reactiverse.pgclient.PgIterator.next:()Lio/reactiverse/pgclient/Row;
astore 2
start local 2 2: aload 2
iconst_0
invokeinterface io.reactiverse.pgclient.Row.getValue:(I)Ljava/lang/Object;
pop
3: aload 2
iconst_0
invokeinterface io.reactiverse.pgclient.Row.getInteger:(I)Ljava/lang/Integer;
pop
end local 2 end local 1 4: return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 1: aload 1
invokeinterface io.reactiverse.pgclient.PgRowSet.iterator:()Lio/reactiverse/pgclient/PgIterator;
invokeinterface io.reactiverse.pgclient.PgIterator.next:()Lio/reactiverse/pgclient/Row;
astore 2
start local 2 2: aload 2
iconst_0
invokeinterface io.reactiverse.pgclient.Row.getValue:(I)Ljava/lang/Object;
pop
3: aload 2
iconst_0
invokeinterface io.reactiverse.pgclient.Row.getInteger:(I)Ljava/lang/Integer;
pop
end local 2 end local 1 4: return
end local 0 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 0: 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
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
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: return
end local 0 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 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Subscribed to channel"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 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 0: 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
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: return
end local 0 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 2
1: 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: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 9
1: 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: 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: 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: 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: aload 0
6: ldc "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaabbbbb"
7: invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.channel:(Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
8: 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: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 0
invokevirtual java.lang.Integer.intValue:()I
bipush 10
if_icmpge 2
1: ldc 100
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
areturn
2: StackMap locals:
StackMap stack:
ldc -1
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
areturn
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifne 2
1: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 7
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: aload 1
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
start local 2 4: 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
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
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 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
end local 1 6: goto 8
7: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
astore 1
start local 1 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
aload 1
invokeinterface io.reactiverse.pgclient.PgRowSet.rowCount:()I
invokevirtual java.io.PrintStream.println:(I)V
end local 1 3: goto 5
4: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
ldc "id"
invokeinterface io.reactiverse.pgclient.Row.getLong:(Ljava/lang/String;)Ljava/lang/Long;
areturn
end local 0 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 0: aload 0
ldc "last_name"
invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
areturn
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgResult
astore 1
start local 1 2: aload 1
invokeinterface io.reactiverse.pgclient.PgResult.value:()Ljava/lang/Object;
checkcast java.util.Map
astore 2
start local 2 3: 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
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 end local 1 4: goto 6
5: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
ldc "last_name"
invokeinterface io.reactiverse.pgclient.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
areturn
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgResult
astore 1
start local 1 2: aload 1
invokeinterface io.reactiverse.pgclient.PgResult.value:()Ljava/lang/Object;
checkcast java.lang.String
astore 2
start local 2 3: 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
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 end local 1 4: goto 6
5: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Query success"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 4
3: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Cancelling request has been sent"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 4
3: 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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: 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: goto 4
3: StackMap locals:
StackMap stack:
aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
4: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: 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: goto 4
3: StackMap locals:
StackMap stack:
aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
4: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: 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: goto 4
3: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
4: StackMap locals:
StackMap stack:
return
end local 2 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 2
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
pop
2: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
pop
2: goto 4
3: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: return
end local 0 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 0: return
end local 0 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 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Transaction succeeded"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 4
3: 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
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: StackMap locals:
StackMap stack:
aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
5: return
end local 1 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 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Transaction failed => rollbacked"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 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 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifne 3
1: aload 0
invokeinterface io.reactiverse.pgclient.PgTransaction.rollback:()V
2: aload 1
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
3: StackMap locals:
StackMap stack:
return
end local 2 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 0: return
end local 0 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 0: aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
1: return
end local 1 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 0: return
end local 0 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 0: return
end local 0 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 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Transaction succeeded"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 4
3: 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
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: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.reactiverse.pgclient.PgRowSet
pop
2: aload 0
invokeinterface io.reactiverse.pgclient.PgCursor.hasMore:()Z
ifne 4
3: aload 1
invokeinterface io.reactiverse.pgclient.PgTransaction.commit:()V
4: StackMap locals:
StackMap stack:
return
end local 2 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 0: 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
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: return
end local 0 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 0: aload 0
invokeinterface io.reactiverse.pgclient.PgTransaction.commit:()V
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "End of stream"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: return
end local 1 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 0: 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
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: return
end local 0 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 0: 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
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: return
end local 0 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 0: 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
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: return
end local 0 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 0: aload 0
invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.actualConnection:()Lio/reactiverse/pgclient/PgConnection;
1: 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: invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
pop
3: return
end local 1 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 0: 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
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: return
end local 0 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 0: aload 0
invokeinterface io.reactiverse.pgclient.pubsub.PgSubscriber.actualConnection:()Lio/reactiverse/pgclient/PgConnection;
1: 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: invokeinterface io.reactiverse.pgclient.PgConnection.query:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/PgConnection;
pop
3: return
end local 1 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 0: 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
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: return
end local 0 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 0: aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
1: return
end local 1 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 0: aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
1: return
end local 1 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 0: aload 0
invokeinterface io.reactiverse.pgclient.PgConnection.close:()V
1: return
end local 1 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 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Notified \"Complex.Channel.Name\""
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 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 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Notified simple_channel"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 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()