public class io.vertx.cassandra.impl.ResultSetImpl implements io.vertx.cassandra.ResultSet
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.cassandra.impl.ResultSetImpl
super_class: java.lang.Object
{
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicReference<com.datastax.oss.driver.api.core.cql.AsyncResultSet> resultSetRef;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;>;
public void <init>(com.datastax.oss.driver.api.core.cql.AsyncResultSet, io.vertx.core.Vertx);
descriptor: (Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
aload 1
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
putfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
2: aload 0
aload 2
putfield io.vertx.cassandra.impl.ResultSetImpl.vertx:Lio/vertx/core/Vertx;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
0 4 1 resultSet Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;
0 4 2 vertx Lio/vertx/core/Vertx;
MethodParameters:
Name Flags
resultSet
vertx
public io.vertx.cassandra.ResultSet all(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<com.datastax.oss.driver.api.core.cql.Row>>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/cassandra/ResultSet;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
aload 1
invokevirtual io.vertx.cassandra.impl.ResultSetImpl.loadMore:(Lio/vertx/core/Context;Ljava/util/List;Lio/vertx/core/Handler;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;)Lio/vertx/cassandra/ResultSet;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.util.List<com.datastax.oss.driver.api.core.cql.Row>> all();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.vertx.cassandra.impl.ResultSetImpl.all:(Lio/vertx/core/Handler;)Lio/vertx/cassandra/ResultSet;
pop
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
Signature: ()Lio/vertx/core/Future<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
public com.datastax.oss.driver.api.core.cql.ColumnDefinitions getColumnDefinitions();
descriptor: ()Lcom/datastax/oss/driver/api/core/cql/ColumnDefinitions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.getColumnDefinitions:()Lcom/datastax/oss/driver/api/core/cql/ColumnDefinitions;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
public com.datastax.oss.driver.api.core.cql.ExecutionInfo getExecutionInfo();
descriptor: ()Lcom/datastax/oss/driver/api/core/cql/ExecutionInfo;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.getExecutionInfo:()Lcom/datastax/oss/driver/api/core/cql/ExecutionInfo;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
public int remaining();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.remaining:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
public java.lang.Iterable<com.datastax.oss.driver.api.core.cql.Row> currentPage();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.currentPage:()Ljava/lang/Iterable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
Signature: ()Ljava/lang/Iterable<Lcom/datastax/oss/driver/api/core/cql/Row;>;
public com.datastax.oss.driver.api.core.cql.Row one();
descriptor: ()Lcom/datastax/oss/driver/api/core/cql/Row;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.one:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.Row
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
public boolean hasMorePages();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.hasMorePages:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
public void fetchNextPage(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.cassandra.ResultSet>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.cassandra.impl.ResultSetImpl.fetchNextPage:()Lio/vertx/core/Future;
astore 2
start local 2 1: aload 1
ifnull 3
2: aload 2
aload 1
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
0 4 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;>;
1 4 2 fut Lio/vertx/core/Future<Lio/vertx/cassandra/ResultSet;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;>;)V
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<io.vertx.cassandra.ResultSet> fetchNextPage();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.fetchNextPage:()Ljava/util/concurrent/CompletionStage;
1: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
2: invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
3: aload 0
invokedynamic apply(Lio/vertx/cassandra/impl/ResultSetImpl;)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;
io/vertx/cassandra/impl/ResultSetImpl.lambda$0(Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/ResultSet; (7)
(Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/ResultSet;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
4: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
Exceptions:
throws java.lang.IllegalStateException
Signature: ()Lio/vertx/core/Future<Lio/vertx/cassandra/ResultSet;>;
public boolean wasApplied();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.wasApplied:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
private void loadMore(io.vertx.core.Context, java.util.List<com.datastax.oss.driver.api.core.cql.Row>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<com.datastax.oss.driver.api.core.cql.Row>>>);
descriptor: (Lio/vertx/core/Context;Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.remaining:()I
istore 4
start local 4 1: new java.util.ArrayList
dup
aload 2
invokeinterface java.util.List.size:()I
iload 4
iadd
invokespecial java.util.ArrayList.<init>:(I)V
astore 5
start local 5 2: aload 5
aload 2
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
3: iconst_0
istore 6
start local 6 4: goto 7
5: StackMap locals: int java.util.List int
StackMap stack:
aload 5
aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.one:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.Row
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
6: iinc 6 1
StackMap locals:
StackMap stack:
7: iload 6
iload 4
if_icmplt 5
end local 6 8: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.hasMorePages:()Z
ifeq 11
9: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokeinterface com.datastax.oss.driver.api.core.cql.AsyncResultSet.fetchNextPage:()Ljava/util/concurrent/CompletionStage;
aload 1
invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
aload 0
aload 1
aload 5
aload 3
invokedynamic handle(Lio/vertx/cassandra/impl/ResultSetImpl;Lio/vertx/core/Context;Ljava/util/List;Lio/vertx/core/Handler;)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
io/vertx/cassandra/impl/ResultSetImpl.lambda$1(Lio/vertx/core/Context;Ljava/util/List;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
10: goto 13
11: StackMap locals:
StackMap stack:
aload 3
ifnull 13
12: aload 3
aload 5
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
13: StackMap locals:
StackMap stack:
return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
0 14 1 context Lio/vertx/core/Context;
0 14 2 loaded Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;
0 14 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;
1 14 4 availableWithoutFetching I
2 14 5 rows Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;
4 8 6 i I
Signature: (Lio/vertx/core/Context;Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;)V
MethodParameters:
Name Flags
context
loaded
handler
private io.vertx.cassandra.ResultSet lambda$0(com.datastax.oss.driver.api.core.cql.AsyncResultSet);
descriptor: (Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/ResultSet;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
0 2 1 datastaxRS Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;
private void lambda$1(io.vertx.core.Context, java.util.List, io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Context;Ljava/util/List;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
getfield io.vertx.cassandra.impl.ResultSetImpl.resultSetRef:Ljava/util/concurrent/atomic/AtomicReference;
aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.AsyncResultSet
invokevirtual java.util.concurrent.atomic.AtomicReference.set:(Ljava/lang/Object;)V
2: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.cassandra.impl.ResultSetImpl.loadMore:(Lio/vertx/core/Context;Ljava/util/List;Lio/vertx/core/Handler;)V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 3
ifnull 6
5: aload 3
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/cassandra/impl/ResultSetImpl;
0 7 4 ar Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;>;
}
SourceFile: "ResultSetImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles