class com.mongodb.operation.ParallelCollectionScanOperation$2 implements com.mongodb.operation.CommandOperationHelper$CommandReadTransformerAsync<org.bson.BsonDocument, java.util.List<com.mongodb.async.AsyncBatchCursor<T>>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.mongodb.operation.ParallelCollectionScanOperation$2
super_class: java.lang.Object
{
final com.mongodb.operation.ParallelCollectionScanOperation this$0;
descriptor: Lcom/mongodb/operation/ParallelCollectionScanOperation;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(com.mongodb.operation.ParallelCollectionScanOperation);
descriptor: (Lcom/mongodb/operation/ParallelCollectionScanOperation;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
aload 1
putfield com.mongodb.operation.ParallelCollectionScanOperation$2.this$0:Lcom/mongodb/operation/ParallelCollectionScanOperation;
aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/operation/ParallelCollectionScanOperation$2;
MethodParameters:
Name Flags
this$0 final
public java.util.List<com.mongodb.async.AsyncBatchCursor<T>> apply(org.bson.BsonDocument, com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection);
descriptor: (Lorg/bson/BsonDocument;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=12, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 4
start local 4 1: aload 0
getfield com.mongodb.operation.ParallelCollectionScanOperation$2.this$0:Lcom/mongodb/operation/ParallelCollectionScanOperation;
aload 1
invokevirtual com.mongodb.operation.ParallelCollectionScanOperation.getCursorDocuments:(Lorg/bson/BsonDocument;)Lorg/bson/BsonArray;
invokevirtual org.bson.BsonArray.iterator:()Ljava/util/Iterator;
astore 6
goto 8
StackMap locals: com.mongodb.operation.ParallelCollectionScanOperation$2 org.bson.BsonDocument com.mongodb.binding.AsyncConnectionSource com.mongodb.connection.AsyncConnection java.util.List top java.util.Iterator
StackMap stack:
2: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.bson.BsonValue
astore 5
start local 5 3: aload 4
new com.mongodb.operation.AsyncQueryBatchCursor
dup
aload 0
getfield com.mongodb.operation.ParallelCollectionScanOperation$2.this$0:Lcom/mongodb/operation/ParallelCollectionScanOperation;
aload 0
getfield com.mongodb.operation.ParallelCollectionScanOperation$2.this$0:Lcom/mongodb/operation/ParallelCollectionScanOperation;
aload 5
invokevirtual org.bson.BsonValue.asDocument:()Lorg/bson/BsonDocument;
invokevirtual com.mongodb.operation.ParallelCollectionScanOperation.getCursorDocument:(Lorg/bson/BsonDocument;)Lorg/bson/BsonDocument;
4: aload 2
invokeinterface com.mongodb.binding.AsyncConnectionSource.getServerDescription:()Lcom/mongodb/connection/ServerDescription;
invokevirtual com.mongodb.connection.ServerDescription.getAddress:()Lcom/mongodb/ServerAddress;
5: invokevirtual com.mongodb.operation.ParallelCollectionScanOperation.createQueryResult:(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult;
6: iconst_0
aload 0
getfield com.mongodb.operation.ParallelCollectionScanOperation$2.this$0:Lcom/mongodb/operation/ParallelCollectionScanOperation;
invokevirtual com.mongodb.operation.ParallelCollectionScanOperation.getBatchSize:()I
lconst_0
aload 0
getfield com.mongodb.operation.ParallelCollectionScanOperation$2.this$0:Lcom/mongodb/operation/ParallelCollectionScanOperation;
getfield com.mongodb.operation.ParallelCollectionScanOperation.decoder:Lorg/bson/codecs/Decoder;
aload 2
aload 3
aload 1
invokespecial com.mongodb.operation.AsyncQueryBatchCursor.<init>:(Lcom/mongodb/connection/QueryResult;IIJLorg/bson/codecs/Decoder;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;Lorg/bson/BsonDocument;)V
7: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 5 8: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
9: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lcom/mongodb/operation/ParallelCollectionScanOperation$2;
0 10 1 result Lorg/bson/BsonDocument;
0 10 2 source Lcom/mongodb/binding/AsyncConnectionSource;
0 10 3 connection Lcom/mongodb/connection/AsyncConnection;
1 10 4 cursors Ljava/util/List<Lcom/mongodb/async/AsyncBatchCursor<TT;>;>;
3 8 5 cursorValue Lorg/bson/BsonValue;
Signature: (Lorg/bson/BsonDocument;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Ljava/util/List<Lcom/mongodb/async/AsyncBatchCursor<TT;>;>;
MethodParameters:
Name Flags
result final
source final
connection final
public java.lang.Object apply(java.lang.Object, com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection);
descriptor: (Ljava/lang/Object;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
checkcast org.bson.BsonDocument
aload 2
aload 3
invokevirtual com.mongodb.operation.ParallelCollectionScanOperation$2.apply:(Lorg/bson/BsonDocument;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Ljava/util/List;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Ljava/lang/Object;Lcom/mongodb/operation/CommandOperationHelper$CommandReadTransformerAsync<Lorg/bson/BsonDocument;Ljava/util/List<Lcom/mongodb/async/AsyncBatchCursor<TT;>;>;>;
SourceFile: "ParallelCollectionScanOperation.java"
EnclosingMethod: com.mongodb.operation.ParallelCollectionScanOperation.asyncTransformer:()Lcom/mongodb/operation/CommandOperationHelper$CommandReadTransformerAsync;
NestHost: com.mongodb.operation.ParallelCollectionScanOperation
InnerClasses:
abstract CommandReadTransformerAsync = com.mongodb.operation.CommandOperationHelper$CommandReadTransformerAsync of com.mongodb.operation.CommandOperationHelper
com.mongodb.operation.ParallelCollectionScanOperation$2