public class examples.RxCassandraClientExamples
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: examples.RxCassandraClientExamples
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/RxCassandraClientExamples;
public void createClient(io.vertx.reactivex.core.Vertx);
descriptor: (Lio/vertx/reactivex/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.cassandra.CassandraClientOptions
dup
invokespecial io.vertx.cassandra.CassandraClientOptions.<init>:()V
1: ldc "node1.corp.int"
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;)Lio/vertx/cassandra/CassandraClientOptions;
2: ldc "node2.corp.int"
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;)Lio/vertx/cassandra/CassandraClientOptions;
3: ldc "node3.corp.int"
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;)Lio/vertx/cassandra/CassandraClientOptions;
4: astore 2
start local 2 5: aload 1
aload 2
invokestatic io.vertx.reactivex.cassandra.CassandraClient.createShared:(Lio/vertx/reactivex/core/Vertx;Lio/vertx/cassandra/CassandraClientOptions;)Lio/vertx/reactivex/cassandra/CassandraClient;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lexamples/RxCassandraClientExamples;
0 7 1 vertx Lio/vertx/reactivex/core/Vertx;
5 7 2 options Lio/vertx/cassandra/CassandraClientOptions;
MethodParameters:
Name Flags
vertx
public void simpleQueryStream(io.vertx.reactivex.cassandra.CassandraClient);
descriptor: (Lio/vertx/reactivex/cassandra/CassandraClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "SELECT my_key FROM my_keyspace.my_table where my_key = my_value"
invokevirtual io.vertx.reactivex.cassandra.CassandraClient.rxQueryStream:(Ljava/lang/String;)Lio/reactivex/Single;
1: invokedynamic apply()Lio/reactivex/functions/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/reactivex/cassandra/CassandraRowStream.toFlowable()Lio/reactivex/Flowable; (5)
(Lio/vertx/reactivex/cassandra/CassandraRowStream;)Lorg/reactivestreams/Publisher;
invokevirtual io.reactivex.Single.flatMapPublisher:(Lio/reactivex/functions/Function;)Lio/reactivex/Flowable;
2: invokedynamic accept()Lio/reactivex/functions/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/RxCassandraClientExamples.lambda$1(Lcom/datastax/driver/core/Row;)V (6)
(Lcom/datastax/driver/core/Row;)V
3: invokedynamic accept()Lio/reactivex/functions/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/RxCassandraClientExamples.lambda$2(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
4: invokedynamic run()Lio/reactivex/functions/Action;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
examples/RxCassandraClientExamples.lambda$3()V (6)
()V
5: invokevirtual io.reactivex.Flowable.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Action;)Lio/reactivex/disposables/Disposable;
pop
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lexamples/RxCassandraClientExamples;
0 7 1 cassandraClient Lio/vertx/reactivex/cassandra/CassandraClient;
MethodParameters:
Name Flags
cassandraClient
public void simpleFullFetch(io.vertx.reactivex.cassandra.CassandraClient);
descriptor: (Lio/vertx/reactivex/cassandra/CassandraClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "SELECT my_key FROM my_keyspace.my_table where my_key = my_value"
invokevirtual io.vertx.reactivex.cassandra.CassandraClient.rxExecuteWithFullFetch:(Ljava/lang/String;)Lio/reactivex/Single;
1: invokedynamic accept()Lio/reactivex/functions/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/RxCassandraClientExamples.lambda$4(Ljava/util/List;)V (6)
(Ljava/util/List;)V
2: invokedynamic accept()Lio/reactivex/functions/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/RxCassandraClientExamples.lambda$5(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
3: invokevirtual io.reactivex.Single.subscribe:(Lio/reactivex/functions/Consumer;Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
pop
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lexamples/RxCassandraClientExamples;
0 5 1 cassandraClient Lio/vertx/reactivex/cassandra/CassandraClient;
MethodParameters:
Name Flags
cassandraClient
private static void lambda$1(com.datastax.driver.core.Row);
descriptor: (Lcom/datastax/driver/core/Row;)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 row Lcom/datastax/driver/core/Row;
Exceptions:
throws java.lang.Exception
private static void lambda$2(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 t Ljava/lang/Throwable;
Exceptions:
throws java.lang.Exception
private static void lambda$3();
descriptor: ()V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=0, args_size=0
0: return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
private static void lambda$4(java.util.List);
descriptor: (Ljava/util/List;)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 rows Ljava/util/List<Lcom/datastax/driver/core/Row;>;
Exceptions:
throws java.lang.Exception
private static void lambda$5(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 throwable Ljava/lang/Throwable;
Exceptions:
throws java.lang.Exception
}
SourceFile: "RxCassandraClientExamples.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles