public class io.vertx.ext.mongo.impl.MongoClientImpl implements io.vertx.ext.mongo.MongoClient, io.vertx.core.Closeable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.mongo.impl.MongoClientImpl
super_class: java.lang.Object
{
private static final io.vertx.ext.mongo.UpdateOptions DEFAULT_UPDATE_OPTIONS;
descriptor: Lio/vertx/ext/mongo/UpdateOptions;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.vertx.ext.mongo.FindOptions DEFAULT_FIND_OPTIONS;
descriptor: Lio/vertx/ext/mongo/FindOptions;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.vertx.ext.mongo.AggregateOptions DEFAULT_AGGREGATE_OPTIONS;
descriptor: Lio/vertx/ext/mongo/AggregateOptions;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.vertx.ext.mongo.BulkWriteOptions DEFAULT_BULK_WRITE_OPTIONS;
descriptor: Lio/vertx/ext/mongo/BulkWriteOptions;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.String DS_LOCAL_MAP_NAME;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "__vertx.MongoClient.datasources"
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.ContextInternal creatingContext;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
protected com.mongodb.reactivestreams.client.MongoClient mongo;
descriptor: Lcom/mongodb/reactivestreams/client/MongoClient;
flags: (0x0004) ACC_PROTECTED
private final io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder holder;
descriptor: Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean useObjectId;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private static volatile int[] $SWITCH_TABLE$io$vertx$ext$mongo$BulkOperation$BulkOperationType;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new io.vertx.ext.mongo.UpdateOptions
dup
invokespecial io.vertx.ext.mongo.UpdateOptions.<init>:()V
putstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_UPDATE_OPTIONS:Lio/vertx/ext/mongo/UpdateOptions;
1: new io.vertx.ext.mongo.FindOptions
dup
invokespecial io.vertx.ext.mongo.FindOptions.<init>:()V
putstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_FIND_OPTIONS:Lio/vertx/ext/mongo/FindOptions;
2: new io.vertx.ext.mongo.AggregateOptions
dup
invokespecial io.vertx.ext.mongo.AggregateOptions.<init>:()V
putstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_AGGREGATE_OPTIONS:Lio/vertx/ext/mongo/AggregateOptions;
3: new io.vertx.ext.mongo.BulkWriteOptions
dup
invokespecial io.vertx.ext.mongo.BulkWriteOptions.<init>:()V
putstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_BULK_WRITE_OPTIONS:Lio/vertx/ext/mongo/BulkWriteOptions;
4: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/json/JsonObject;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 3
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
5: aload 0
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
putfield io.vertx.ext.mongo.impl.MongoClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
6: aload 0
aload 0
aload 3
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.lookupHolder:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
putfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
7: aload 0
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.mongo:(Lio/vertx/core/Vertx;)Lcom/mongodb/reactivestreams/client/MongoClient;
putfield io.vertx.ext.mongo.impl.MongoClientImpl.mongo:Lcom/mongodb/reactivestreams/client/MongoClient;
8: aload 0
aload 2
ldc "useObjectId"
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
putfield io.vertx.ext.mongo.impl.MongoClientImpl.useObjectId:Z
9: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
aload 0
invokeinterface io.vertx.core.impl.ContextInternal.addCloseHook:(Lio/vertx/core/Closeable;)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 Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 11 1 vertx Lio/vertx/core/Vertx;
0 11 2 config Lio/vertx/core/json/JsonObject;
0 11 3 dataSourceName Ljava/lang/String;
MethodParameters:
Name Flags
vertx
config
dataSourceName
public void <init>(io.vertx.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String, com.mongodb.MongoClientSettings);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/json/JsonObject;Ljava/lang/String;Lcom/mongodb/MongoClientSettings;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 3
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 4
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
6: aload 0
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
putfield io.vertx.ext.mongo.impl.MongoClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
7: aload 0
aload 0
aload 3
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.lookupHolder:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
putfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
8: aload 0
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
aload 1
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.mongo:(Lio/vertx/core/Vertx;Lcom/mongodb/MongoClientSettings;)Lcom/mongodb/reactivestreams/client/MongoClient;
putfield io.vertx.ext.mongo.impl.MongoClientImpl.mongo:Lcom/mongodb/reactivestreams/client/MongoClient;
9: aload 0
aload 2
ldc "useObjectId"
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
putfield io.vertx.ext.mongo.impl.MongoClientImpl.useObjectId:Z
10: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
aload 0
invokeinterface io.vertx.core.impl.ContextInternal.addCloseHook:(Lio/vertx/core/Closeable;)V
11: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 12 1 vertx Lio/vertx/core/Vertx;
0 12 2 config Lio/vertx/core/json/JsonObject;
0 12 3 dataSourceName Ljava/lang/String;
0 12 4 settings Lcom/mongodb/MongoClientSettings;
MethodParameters:
Name Flags
vertx
config
dataSourceName
settings
public void close(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.close:()V
1: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 completionHandler Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.Future<java.lang.Void> close();
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.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.close:()V
1: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
aload 0
invokeinterface io.vertx.core.impl.ContextInternal.removeCloseHook:(Lio/vertx/core/Closeable;)V
2: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.ext.mongo.MongoClient save(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.save:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 document Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
document
resultHandler
public io.vertx.core.Future<java.lang.String> save(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.saveWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 document Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Ljava/lang/String;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
document
public io.vertx.ext.mongo.MongoClient saveWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.saveWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 document Lio/vertx/core/json/JsonObject;
0 3 3 writeOption Lio/vertx/ext/mongo/WriteOption;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 3 5 future Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoClient;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
document
writeOption
resultHandler
public io.vertx.core.Future<java.lang.String> saveWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "document cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 3: aload 2
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
astore 5
start local 5 4: aload 5
ifnonnull 8
5: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 6
start local 6 6: aload 4
aload 2
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.insertOne:(Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 6
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
7: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
aload 2
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoClientImpl;Lio/vertx/core/json/JsonObject;)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/ext/mongo/impl/MongoClientImpl.lambda$0(Lio/vertx/core/json/JsonObject;Ljava/lang/Void;)Ljava/lang/String; (7)
(Ljava/lang/Void;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 6 8: StackMap locals: com.mongodb.reactivestreams.client.MongoCollection java.lang.Object
StackMap stack:
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 6
start local 6 9: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 7
start local 7 10: aload 6
ldc "_id"
aload 7
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
11: new com.mongodb.client.model.ReplaceOptions
dup
invokespecial com.mongodb.client.model.ReplaceOptions.<init>:()V
iconst_1
invokevirtual com.mongodb.client.model.ReplaceOptions.upsert:(Z)Lcom/mongodb/client/model/ReplaceOptions;
astore 8
start local 8 12: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 9
start local 9 13: aload 4
aload 0
aload 6
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
aload 7
aload 8
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.replaceOne:(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/ReplaceOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 9
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
14: aload 9
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.mapEmpty:()Lio/vertx/core/Future;
areturn
end local 9 end local 8 end local 7 end local 6 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 15 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 15 1 collection Ljava/lang/String;
0 15 2 document Lio/vertx/core/json/JsonObject;
0 15 3 writeOption Lio/vertx/ext/mongo/WriteOption;
3 15 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
4 15 5 id Ljava/lang/Object;
6 8 6 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
9 15 6 filter Lio/vertx/core/json/JsonObject;
10 15 7 encodedDocument Lio/vertx/core/json/JsonObject;
12 15 8 replaceOptions Lcom/mongodb/client/model/ReplaceOptions;
13 15 9 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future<Ljava/lang/String;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
document
writeOption
public io.vertx.ext.mongo.MongoClient insert(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.insert:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 document Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
document
resultHandler
public io.vertx.core.Future<java.lang.String> insert(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.insertWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 document Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Ljava/lang/String;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
document
public io.vertx.ext.mongo.MongoClient insertWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.insertWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 document Lio/vertx/core/json/JsonObject;
0 3 3 writeOption Lio/vertx/ext/mongo/WriteOption;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 3 5 future Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoClient;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
document
writeOption
resultHandler
public io.vertx.core.Future<java.lang.String> insertWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "document cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 4
start local 4 3: aload 2
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.containsKey:(Ljava/lang/String;)Z
istore 5
start local 5 4: aload 0
aload 1
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 6
start local 6 5: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 7
start local 7 6: aload 6
aload 4
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.insertOne:(Ljava/lang/Object;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 7
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
7: aload 7
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
iload 5
aload 4
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoClientImpl;ZLio/vertx/core/json/JsonObject;)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/ext/mongo/impl/MongoClientImpl.lambda$1(ZLio/vertx/core/json/JsonObject;Ljava/lang/Void;)Ljava/lang/String; (7)
(Ljava/lang/Void;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 7 end local 6 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 8 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 8 1 collection Ljava/lang/String;
0 8 2 document Lio/vertx/core/json/JsonObject;
0 8 3 writeOption Lio/vertx/ext/mongo/WriteOption;
3 8 4 encodedDocument Lio/vertx/core/json/JsonObject;
4 8 5 hasCustomId Z
5 8 6 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
6 8 7 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future<Ljava/lang/String;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
document
writeOption
public io.vertx.ext.mongo.MongoClient updateCollection(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientUpdateResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.updateCollection:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 update Lio/vertx/core/json/JsonObject;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
update
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientUpdateResult> updateCollection(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_UPDATE_OPTIONS:Lio/vertx/ext/mongo/UpdateOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.updateCollectionWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
0 1 3 update Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
update
public io.vertx.ext.mongo.MongoClient updateCollectionWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.UpdateOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientUpdateResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.updateCollectionWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
astore 6
start local 6 1: aload 6
aload 5
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 6 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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 update Lio/vertx/core/json/JsonObject;
0 3 4 options Lio/vertx/ext/mongo/UpdateOptions;
0 3 5 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;
1 3 6 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
update
options
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientUpdateResult> updateCollectionWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.UpdateOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=11, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "update cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 4
ldc "options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 0
aload 1
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.getWriteOption:()Lio/vertx/ext/mongo/WriteOption;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 5
start local 5 5: aload 0
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 6
start local 6 6: aload 0
aload 0
aload 0
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.generateIdIfNeeded:(Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 7
start local 7 7: new com.mongodb.client.model.UpdateOptions
dup
invokespecial com.mongodb.client.model.UpdateOptions.<init>:()V
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.isUpsert:()Z
invokevirtual com.mongodb.client.model.UpdateOptions.upsert:(Z)Lcom/mongodb/client/model/UpdateOptions;
astore 8
start local 8 8: aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
ifnull 12
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
invokevirtual io.vertx.core.json.JsonArray.isEmpty:()Z
ifne 12
9: new java.util.ArrayList
dup
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
invokevirtual io.vertx.core.json.JsonArray.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 9
start local 9 10: aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
invokevirtual io.vertx.core.json.JsonArray.getList:()Ljava/util/List;
aload 0
aload 9
invokedynamic accept(Lio/vertx/ext/mongo/impl/MongoClientImpl;Ljava/util/List;)Ljava/util/function/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
io/vertx/ext/mongo/impl/MongoClientImpl.lambda$2(Ljava/util/List;Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
11: aload 8
aload 9
invokevirtual com.mongodb.client.model.UpdateOptions.arrayFilters:(Ljava/util/List;)Lcom/mongodb/client/model/UpdateOptions;
pop
end local 9 12: StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.lang.String io.vertx.core.json.JsonObject io.vertx.core.json.JsonObject io.vertx.ext.mongo.UpdateOptions com.mongodb.reactivestreams.client.MongoCollection org.bson.conversions.Bson org.bson.conversions.Bson com.mongodb.client.model.UpdateOptions
StackMap stack:
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.isMulti:()Z
ifeq 15
13: aload 5
aload 6
aload 7
aload 8
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.updateMany:(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;
astore 9
start local 9 14: goto 16
end local 9 15: StackMap locals:
StackMap stack:
aload 5
aload 6
aload 7
aload 8
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.updateOne:(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)Lorg/reactivestreams/Publisher;
astore 9
start local 9 16: StackMap locals: org.reactivestreams.Publisher
StackMap stack:
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 10
start local 10 17: aload 9
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 10
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
18: aload 10
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
io/vertx/ext/mongo/impl/Utils.toMongoClientUpdateResult(Lcom/mongodb/client/result/UpdateResult;)Lio/vertx/ext/mongo/MongoClientUpdateResult; (6)
(Lcom/mongodb/client/result/UpdateResult;)Lio/vertx/ext/mongo/MongoClientUpdateResult;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 10 end local 9 end local 8 end local 7 end local 6 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 19 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 19 1 collection Ljava/lang/String;
0 19 2 query Lio/vertx/core/json/JsonObject;
0 19 3 update Lio/vertx/core/json/JsonObject;
0 19 4 options Lio/vertx/ext/mongo/UpdateOptions;
5 19 5 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
6 19 6 bquery Lorg/bson/conversions/Bson;
7 19 7 bupdate Lorg/bson/conversions/Bson;
8 19 8 updateOptions Lcom/mongodb/client/model/UpdateOptions;
10 12 9 bArrayFilters Ljava/util/List<Lorg/bson/conversions/Bson;>;
14 15 9 publisher Lorg/reactivestreams/Publisher<Lcom/mongodb/client/result/UpdateResult;>;
16 19 9 publisher Lorg/reactivestreams/Publisher<Lcom/mongodb/client/result/UpdateResult;>;
17 19 10 promise Lio/vertx/core/Promise<Lcom/mongodb/client/result/UpdateResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
update
options
private io.vertx.core.json.JsonObject generateIdIfNeeded(io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.UpdateOptions);
descriptor: (Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/json/JsonObject;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
invokevirtual io.vertx.ext.mongo.UpdateOptions.isUpsert:()Z
ifeq 8
aload 2
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.containsKey:(Ljava/lang/String;)Z
ifne 8
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.useObjectId:Z
ifne 8
1: aload 2
ldc "$setOnInsert"
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
invokevirtual io.vertx.core.json.JsonObject.getJsonObject:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 4
start local 4 2: aload 1
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.containsKey:(Ljava/lang/String;)Z
ifeq 5
3: aload 1
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 5
start local 5 4: goto 6
end local 5 5: StackMap locals: io.vertx.core.json.JsonObject
StackMap stack:
invokestatic io.vertx.ext.mongo.impl.codec.json.JsonObjectCodec.generateHexObjectId:()Ljava/lang/String;
astore 5
start local 5 6: StackMap locals: java.lang.String
StackMap stack:
aload 4
ldc "_id"
aload 5
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
7: aload 2
ldc "$setOnInsert"
aload 4
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
end local 5 end local 4 8: StackMap locals:
StackMap stack:
aload 2
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 9 1 query Lio/vertx/core/json/JsonObject;
0 9 2 update Lio/vertx/core/json/JsonObject;
0 9 3 options Lio/vertx/ext/mongo/UpdateOptions;
2 8 4 setId Lio/vertx/core/json/JsonObject;
4 5 5 id Ljava/lang/String;
6 8 5 id Ljava/lang/String;
MethodParameters:
Name Flags
query
update
options
public io.vertx.ext.mongo.MongoClient replaceDocuments(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientUpdateResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_UPDATE_OPTIONS:Lio/vertx/ext/mongo/UpdateOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.replaceDocumentsWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 replace Lio/vertx/core/json/JsonObject;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
replace
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientUpdateResult> replaceDocuments(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_UPDATE_OPTIONS:Lio/vertx/ext/mongo/UpdateOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.replaceDocumentsWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
0 1 3 replace Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
replace
public io.vertx.ext.mongo.MongoClient replaceDocumentsWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.UpdateOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientUpdateResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.replaceDocumentsWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
astore 6
start local 6 1: aload 6
aload 5
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 6 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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 replace Lio/vertx/core/json/JsonObject;
0 3 4 options Lio/vertx/ext/mongo/UpdateOptions;
0 3 5 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;
1 3 6 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
replace
options
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientUpdateResult> replaceDocumentsWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.UpdateOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "update cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 4
ldc "options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 0
aload 1
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.getWriteOption:()Lio/vertx/ext/mongo/WriteOption;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 5
start local 5 5: aload 0
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 6
start local 6 6: new com.mongodb.client.model.ReplaceOptions
dup
invokespecial com.mongodb.client.model.ReplaceOptions.<init>:()V
aload 4
invokevirtual io.vertx.ext.mongo.UpdateOptions.isUpsert:()Z
invokevirtual com.mongodb.client.model.ReplaceOptions.upsert:(Z)Lcom/mongodb/client/model/ReplaceOptions;
astore 7
start local 7 7: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 8
start local 8 8: aload 5
aload 6
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
aload 7
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.replaceOne:(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/ReplaceOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 8
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
9: aload 8
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
io/vertx/ext/mongo/impl/Utils.toMongoClientUpdateResult(Lcom/mongodb/client/result/UpdateResult;)Lio/vertx/ext/mongo/MongoClientUpdateResult; (6)
(Lcom/mongodb/client/result/UpdateResult;)Lio/vertx/ext/mongo/MongoClientUpdateResult;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 8 end local 7 end local 6 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 10 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 10 1 collection Ljava/lang/String;
0 10 2 query Lio/vertx/core/json/JsonObject;
0 10 3 replace Lio/vertx/core/json/JsonObject;
0 10 4 options Lio/vertx/ext/mongo/UpdateOptions;
5 10 5 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
6 10 6 bquery Lorg/bson/conversions/Bson;
7 10 7 replaceOptions Lcom/mongodb/client/model/ReplaceOptions;
8 10 8 promise Lio/vertx/core/Promise<Lcom/mongodb/client/result/UpdateResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientUpdateResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
replace
options
public io.vertx.ext.mongo.MongoClient find(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.core.json.JsonObject>>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.find:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
resultHandler
public io.vertx.core.Future<java.util.List<io.vertx.core.json.JsonObject>> find(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_FIND_OPTIONS:Lio/vertx/ext/mongo/FindOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;
MethodParameters:
Name Flags
collection
query
public io.vertx.ext.mongo.MongoClient findWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.core.json.JsonObject>>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 options Lio/vertx/ext/mongo/FindOptions;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;>;
1 3 5 future Lio/vertx/core/Future<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
options
resultHandler
public io.vertx.core.Future<java.util.List<io.vertx.core.json.JsonObject>> findWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 3: aload 0
aload 1
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.doFind:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lcom/mongodb/reactivestreams/client/FindPublisher;
4: new io.vertx.ext.mongo.impl.MappingAndBufferingSubscriber
dup
aload 0
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoClientImpl;)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/ext/mongo/impl/MongoClientImpl.decodeKeyWhenUseObjectId(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject; (7)
(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
aload 4
invokespecial io.vertx.ext.mongo.impl.MappingAndBufferingSubscriber.<init>:(Ljava/util/function/Function;Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
5: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 6 1 collection Ljava/lang/String;
0 6 2 query Lio/vertx/core/json/JsonObject;
0 6 3 options Lio/vertx/ext/mongo/FindOptions;
3 6 4 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;
MethodParameters:
Name Flags
collection
query
options
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> findBatch(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_FIND_OPTIONS:Lio/vertx/ext/mongo/FindOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findBatchWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/streams/ReadStream;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection
query
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> findBatchWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.doFind:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lcom/mongodb/reactivestreams/client/FindPublisher;
astore 4
start local 4 3: new io.vertx.ext.mongo.impl.PublisherAdapter
dup
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 4
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getBatchSize:()I
invokespecial io.vertx.ext.mongo.impl.PublisherAdapter.<init>:(Lio/vertx/core/impl/ContextInternal;Lorg/reactivestreams/Publisher;I)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 4 1 collection Ljava/lang/String;
0 4 2 query Lio/vertx/core/json/JsonObject;
0 4 3 options Lio/vertx/ext/mongo/FindOptions;
3 4 4 view Lcom/mongodb/reactivestreams/client/FindPublisher<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection
query
options
public io.vertx.ext.mongo.MongoClient findOne(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOne:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 fields Lio/vertx/core/json/JsonObject;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
fields
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOne(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 4
start local 4 3: aload 0
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 5
start local 5 4: aload 0
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 6
start local 6 5: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 7
start local 7 6: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
aload 5
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.find:(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;
aload 6
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.projection:(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.first:()Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 7
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
7: aload 7
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 0
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoClientImpl;)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/ext/mongo/impl/MongoClientImpl.lambda$6(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject; (7)
(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 7 end local 6 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 8 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 8 1 collection Ljava/lang/String;
0 8 2 query Lio/vertx/core/json/JsonObject;
0 8 3 fields Lio/vertx/core/json/JsonObject;
3 8 4 encodedQuery Lio/vertx/core/json/JsonObject;
4 8 5 bquery Lorg/bson/conversions/Bson;
5 8 6 bfields Lorg/bson/conversions/Bson;
6 8 7 promise Lio/vertx/core/Promise<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
fields
public io.vertx.ext.mongo.MongoClient findOneAndUpdate(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndUpdate:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 update Lio/vertx/core/json/JsonObject;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
update
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOneAndUpdate(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_FIND_OPTIONS:Lio/vertx/ext/mongo/FindOptions;
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_UPDATE_OPTIONS:Lio/vertx/ext/mongo/UpdateOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndUpdateWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
0 1 3 update Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
update
public io.vertx.ext.mongo.MongoClient findOneAndUpdateWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions, io.vertx.ext.mongo.UpdateOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
aload 3
aload 4
aload 5
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndUpdateWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
astore 7
start local 7 1: aload 7
aload 6
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 7 end local 6 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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 update Lio/vertx/core/json/JsonObject;
0 3 4 findOptions Lio/vertx/ext/mongo/FindOptions;
0 3 5 updateOptions Lio/vertx/ext/mongo/UpdateOptions;
0 3 6 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 7 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
update
findOptions
updateOptions
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOneAndUpdateWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions, io.vertx.ext.mongo.UpdateOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=12, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "update cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 4
ldc "find options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 5
ldc "update options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
5: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 6
start local 6 6: aload 0
aload 6
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 7
start local 7 7: aload 0
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 8
start local 8 8: new com.mongodb.client.model.FindOneAndUpdateOptions
dup
invokespecial com.mongodb.client.model.FindOneAndUpdateOptions.<init>:()V
astore 9
start local 9 9: aload 9
aload 0
aload 4
invokevirtual io.vertx.ext.mongo.FindOptions.getSort:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokevirtual com.mongodb.client.model.FindOneAndUpdateOptions.sort:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/FindOneAndUpdateOptions;
pop
10: aload 9
aload 0
aload 4
invokevirtual io.vertx.ext.mongo.FindOptions.getFields:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokevirtual com.mongodb.client.model.FindOneAndUpdateOptions.projection:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/FindOneAndUpdateOptions;
pop
11: aload 9
aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.isUpsert:()Z
invokevirtual com.mongodb.client.model.FindOneAndUpdateOptions.upsert:(Z)Lcom/mongodb/client/model/FindOneAndUpdateOptions;
pop
12: aload 9
aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.isReturningNewDocument:()Z
ifeq 13
getstatic com.mongodb.client.model.ReturnDocument.AFTER:Lcom/mongodb/client/model/ReturnDocument;
goto 14
StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.lang.String io.vertx.core.json.JsonObject io.vertx.core.json.JsonObject io.vertx.ext.mongo.FindOptions io.vertx.ext.mongo.UpdateOptions io.vertx.core.json.JsonObject org.bson.conversions.Bson org.bson.conversions.Bson com.mongodb.client.model.FindOneAndUpdateOptions
StackMap stack: com.mongodb.client.model.FindOneAndUpdateOptions
13: getstatic com.mongodb.client.model.ReturnDocument.BEFORE:Lcom/mongodb/client/model/ReturnDocument;
StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.lang.String io.vertx.core.json.JsonObject io.vertx.core.json.JsonObject io.vertx.ext.mongo.FindOptions io.vertx.ext.mongo.UpdateOptions io.vertx.core.json.JsonObject org.bson.conversions.Bson org.bson.conversions.Bson com.mongodb.client.model.FindOneAndUpdateOptions
StackMap stack: com.mongodb.client.model.FindOneAndUpdateOptions com.mongodb.client.model.ReturnDocument
14: invokevirtual com.mongodb.client.model.FindOneAndUpdateOptions.returnDocument:(Lcom/mongodb/client/model/ReturnDocument;)Lcom/mongodb/client/model/FindOneAndUpdateOptions;
pop
15: aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
ifnull 19
aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
invokevirtual io.vertx.core.json.JsonArray.isEmpty:()Z
ifne 19
16: new java.util.ArrayList
dup
aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
invokevirtual io.vertx.core.json.JsonArray.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 10
start local 10 17: aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.getArrayFilters:()Lio/vertx/core/json/JsonArray;
invokevirtual io.vertx.core.json.JsonArray.getList:()Ljava/util/List;
aload 0
aload 10
invokedynamic accept(Lio/vertx/ext/mongo/impl/MongoClientImpl;Ljava/util/List;)Ljava/util/function/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
io/vertx/ext/mongo/impl/MongoClientImpl.lambda$7(Ljava/util/List;Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
18: aload 9
aload 10
invokevirtual com.mongodb.client.model.FindOneAndUpdateOptions.arrayFilters:(Ljava/util/List;)Lcom/mongodb/client/model/FindOneAndUpdateOptions;
pop
end local 10 19: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 10
start local 10 20: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 11
start local 11 21: aload 10
aload 7
aload 8
aload 9
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.findOneAndUpdate:(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndUpdateOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 11
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
22: aload 11
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 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 23 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 23 1 collection Ljava/lang/String;
0 23 2 query Lio/vertx/core/json/JsonObject;
0 23 3 update Lio/vertx/core/json/JsonObject;
0 23 4 findOptions Lio/vertx/ext/mongo/FindOptions;
0 23 5 updateOptions Lio/vertx/ext/mongo/UpdateOptions;
6 23 6 encodedQuery Lio/vertx/core/json/JsonObject;
7 23 7 bquery Lorg/bson/conversions/Bson;
8 23 8 bupdate Lorg/bson/conversions/Bson;
9 23 9 foauOptions Lcom/mongodb/client/model/FindOneAndUpdateOptions;
17 19 10 bArrayFilters Ljava/util/List<Lorg/bson/conversions/Bson;>;
20 23 10 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
21 23 11 promise Lio/vertx/core/Promise<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
update
findOptions
updateOptions
public io.vertx.ext.mongo.MongoClient findOneAndReplace(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndReplace:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 replace Lio/vertx/core/json/JsonObject;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
replace
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOneAndReplace(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_FIND_OPTIONS:Lio/vertx/ext/mongo/FindOptions;
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_UPDATE_OPTIONS:Lio/vertx/ext/mongo/UpdateOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndReplaceWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
0 1 3 replace Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
replace
public io.vertx.ext.mongo.MongoClient findOneAndReplaceWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions, io.vertx.ext.mongo.UpdateOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
aload 3
aload 4
aload 5
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndReplaceWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
astore 7
start local 7 1: aload 7
aload 6
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 7 end local 6 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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 replace Lio/vertx/core/json/JsonObject;
0 3 4 findOptions Lio/vertx/ext/mongo/FindOptions;
0 3 5 updateOptions Lio/vertx/ext/mongo/UpdateOptions;
0 3 6 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 7 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
replace
findOptions
updateOptions
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOneAndReplaceWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions, io.vertx.ext.mongo.UpdateOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 4
ldc "find options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 5
ldc "update options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 6
start local 6 5: aload 0
aload 6
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 7
start local 7 6: new com.mongodb.client.model.FindOneAndReplaceOptions
dup
invokespecial com.mongodb.client.model.FindOneAndReplaceOptions.<init>:()V
astore 8
start local 8 7: aload 8
aload 0
aload 4
invokevirtual io.vertx.ext.mongo.FindOptions.getSort:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokevirtual com.mongodb.client.model.FindOneAndReplaceOptions.sort:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/FindOneAndReplaceOptions;
pop
8: aload 8
aload 0
aload 4
invokevirtual io.vertx.ext.mongo.FindOptions.getFields:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokevirtual com.mongodb.client.model.FindOneAndReplaceOptions.projection:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/FindOneAndReplaceOptions;
pop
9: aload 8
aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.isUpsert:()Z
invokevirtual com.mongodb.client.model.FindOneAndReplaceOptions.upsert:(Z)Lcom/mongodb/client/model/FindOneAndReplaceOptions;
pop
10: aload 8
aload 5
invokevirtual io.vertx.ext.mongo.UpdateOptions.isReturningNewDocument:()Z
ifeq 11
getstatic com.mongodb.client.model.ReturnDocument.AFTER:Lcom/mongodb/client/model/ReturnDocument;
goto 12
StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.lang.String io.vertx.core.json.JsonObject io.vertx.core.json.JsonObject io.vertx.ext.mongo.FindOptions io.vertx.ext.mongo.UpdateOptions io.vertx.core.json.JsonObject org.bson.conversions.Bson com.mongodb.client.model.FindOneAndReplaceOptions
StackMap stack: com.mongodb.client.model.FindOneAndReplaceOptions
11: getstatic com.mongodb.client.model.ReturnDocument.BEFORE:Lcom/mongodb/client/model/ReturnDocument;
StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.lang.String io.vertx.core.json.JsonObject io.vertx.core.json.JsonObject io.vertx.ext.mongo.FindOptions io.vertx.ext.mongo.UpdateOptions io.vertx.core.json.JsonObject org.bson.conversions.Bson com.mongodb.client.model.FindOneAndReplaceOptions
StackMap stack: com.mongodb.client.model.FindOneAndReplaceOptions com.mongodb.client.model.ReturnDocument
12: invokevirtual com.mongodb.client.model.FindOneAndReplaceOptions.returnDocument:(Lcom/mongodb/client/model/ReturnDocument;)Lcom/mongodb/client/model/FindOneAndReplaceOptions;
pop
13: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 9
start local 9 14: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 10
start local 10 15: aload 9
aload 7
aload 3
aload 8
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.findOneAndReplace:(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/FindOneAndReplaceOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 10
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
16: aload 10
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 10 end local 9 end local 8 end local 7 end local 6 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 17 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 17 1 collection Ljava/lang/String;
0 17 2 query Lio/vertx/core/json/JsonObject;
0 17 3 replace Lio/vertx/core/json/JsonObject;
0 17 4 findOptions Lio/vertx/ext/mongo/FindOptions;
0 17 5 updateOptions Lio/vertx/ext/mongo/UpdateOptions;
5 17 6 encodedQuery Lio/vertx/core/json/JsonObject;
6 17 7 bquery Lorg/bson/conversions/Bson;
7 17 8 foarOptions Lcom/mongodb/client/model/FindOneAndReplaceOptions;
14 17 9 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
15 17 10 promise Lio/vertx/core/Promise<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/ext/mongo/UpdateOptions;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
replace
findOptions
updateOptions
public io.vertx.ext.mongo.MongoClient findOneAndDelete(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndDelete:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 4 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOneAndDelete(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_FIND_OPTIONS:Lio/vertx/ext/mongo/FindOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndDeleteWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
public io.vertx.ext.mongo.MongoClient findOneAndDeleteWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findOneAndDeleteWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 findOptions Lio/vertx/ext/mongo/FindOptions;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
findOptions
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> findOneAndDeleteWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "find options cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 4
start local 4 4: aload 0
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 5
start local 5 5: new com.mongodb.client.model.FindOneAndDeleteOptions
dup
invokespecial com.mongodb.client.model.FindOneAndDeleteOptions.<init>:()V
astore 6
start local 6 6: aload 6
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getSort:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokevirtual com.mongodb.client.model.FindOneAndDeleteOptions.sort:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/FindOneAndDeleteOptions;
pop
7: aload 6
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getFields:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokevirtual com.mongodb.client.model.FindOneAndDeleteOptions.projection:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/FindOneAndDeleteOptions;
pop
8: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 7
start local 7 9: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 8
start local 8 10: aload 7
aload 5
aload 6
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.findOneAndDelete:(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/FindOneAndDeleteOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 8
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
11: aload 8
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 8 end local 7 end local 6 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 12 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 12 1 collection Ljava/lang/String;
0 12 2 query Lio/vertx/core/json/JsonObject;
0 12 3 findOptions Lio/vertx/ext/mongo/FindOptions;
4 12 4 encodedQuery Lio/vertx/core/json/JsonObject;
5 12 5 bquery Lorg/bson/conversions/Bson;
6 12 6 foadOptions Lcom/mongodb/client/model/FindOneAndDeleteOptions;
9 12 7 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
10 12 8 promise Lio/vertx/core/Promise<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
findOptions
public io.vertx.ext.mongo.MongoClient count(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.count:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/lang/Long;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
resultHandler
public io.vertx.core.Future<java.lang.Long> count(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 3
start local 3 3: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 4: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 5
start local 5 5: aload 4
aload 3
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.countDocuments:(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 5
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
6: aload 5
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
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 7 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 7 1 collection Ljava/lang/String;
0 7 2 query Lio/vertx/core/json/JsonObject;
3 7 3 bquery Lorg/bson/conversions/Bson;
4 7 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
5 7 5 promise Lio/vertx/core/Promise<Ljava/lang/Long;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
collection
query
public io.vertx.ext.mongo.MongoClient removeDocuments(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientDeleteResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeDocuments:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;
1 3 4 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientDeleteResult> removeDocuments(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeDocumentsWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
public io.vertx.ext.mongo.MongoClient removeDocumentsWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientDeleteResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeDocumentsWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 writeOption Lio/vertx/ext/mongo/WriteOption;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
writeOption
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientDeleteResult> removeDocumentsWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 3: aload 0
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 5
start local 5 4: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 6
start local 6 5: aload 4
aload 5
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.deleteMany:(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 6
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
6: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
io/vertx/ext/mongo/impl/Utils.toMongoClientDeleteResult(Lcom/mongodb/client/result/DeleteResult;)Lio/vertx/ext/mongo/MongoClientDeleteResult; (6)
(Lcom/mongodb/client/result/DeleteResult;)Lio/vertx/ext/mongo/MongoClientDeleteResult;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 6 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 7 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 7 1 collection Ljava/lang/String;
0 7 2 query Lio/vertx/core/json/JsonObject;
0 7 3 writeOption Lio/vertx/ext/mongo/WriteOption;
3 7 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
4 7 5 bquery Lorg/bson/conversions/Bson;
5 7 6 promise Lio/vertx/core/Promise<Lcom/mongodb/client/result/DeleteResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
writeOption
public io.vertx.ext.mongo.MongoClient removeDocument(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientDeleteResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeDocument:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;
1 3 4 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
query
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientDeleteResult> removeDocument(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeDocumentWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 query Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
public io.vertx.ext.mongo.MongoClient removeDocumentWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientDeleteResult>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeDocumentWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 query Lio/vertx/core/json/JsonObject;
0 3 3 writeOption Lio/vertx/ext/mongo/WriteOption;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
writeOption
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientDeleteResult> removeDocumentWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.WriteOption);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 3: aload 0
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 5
start local 5 4: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 6
start local 6 5: aload 4
aload 5
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.deleteOne:(Lorg/bson/conversions/Bson;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 6
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
6: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
io/vertx/ext/mongo/impl/Utils.toMongoClientDeleteResult(Lcom/mongodb/client/result/DeleteResult;)Lio/vertx/ext/mongo/MongoClientDeleteResult; (6)
(Lcom/mongodb/client/result/DeleteResult;)Lio/vertx/ext/mongo/MongoClientDeleteResult;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 6 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 7 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 7 1 collection Ljava/lang/String;
0 7 2 query Lio/vertx/core/json/JsonObject;
0 7 3 writeOption Lio/vertx/ext/mongo/WriteOption;
3 7 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
4 7 5 bquery Lorg/bson/conversions/Bson;
5 7 6 promise Lio/vertx/core/Promise<Lcom/mongodb/client/result/DeleteResult;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/WriteOption;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientDeleteResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
query
writeOption
public io.vertx.ext.mongo.MongoClient bulkWrite(java.lang.String, java.util.List<io.vertx.ext.mongo.BulkOperation>, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientBulkWriteResult>>);
descriptor: (Ljava/lang/String;Ljava/util/List;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.bulkWrite:(Ljava/lang/String;Ljava/util/List;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 operations Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;>;
1 3 4 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;
Signature: (Ljava/lang/String;Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
operations
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientBulkWriteResult> bulkWrite(java.lang.String, java.util.List<io.vertx.ext.mongo.BulkOperation>);
descriptor: (Ljava/lang/String;Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_BULK_WRITE_OPTIONS:Lio/vertx/ext/mongo/BulkWriteOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.bulkWriteWithOptions:(Ljava/lang/String;Ljava/util/List;Lio/vertx/ext/mongo/BulkWriteOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 operations Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;
Signature: (Ljava/lang/String;Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
operations
public io.vertx.ext.mongo.MongoClient bulkWriteWithOptions(java.lang.String, java.util.List<io.vertx.ext.mongo.BulkOperation>, io.vertx.ext.mongo.BulkWriteOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoClientBulkWriteResult>>);
descriptor: (Ljava/lang/String;Ljava/util/List;Lio/vertx/ext/mongo/BulkWriteOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.bulkWriteWithOptions:(Ljava/lang/String;Ljava/util/List;Lio/vertx/ext/mongo/BulkWriteOptions;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 operations Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;
0 3 3 bulkWriteOptions Lio/vertx/ext/mongo/BulkWriteOptions;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;
Signature: (Ljava/lang/String;Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;Lio/vertx/ext/mongo/BulkWriteOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
operations
bulkWriteOptions
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoClientBulkWriteResult> bulkWriteWithOptions(java.lang.String, java.util.List<io.vertx.ext.mongo.BulkOperation>, io.vertx.ext.mongo.BulkWriteOptions);
descriptor: (Ljava/lang/String;Ljava/util/List;Lio/vertx/ext/mongo/BulkWriteOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "operations cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "bulkWriteOptions cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
aload 3
invokevirtual io.vertx.ext.mongo.BulkWriteOptions.getWriteOption:()Lio/vertx/ext/mongo/WriteOption;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 4: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.convertBulkOperations:(Ljava/util/List;)Ljava/util/List;
astore 5
start local 5 5: new com.mongodb.client.model.BulkWriteOptions
dup
invokespecial com.mongodb.client.model.BulkWriteOptions.<init>:()V
aload 3
invokevirtual io.vertx.ext.mongo.BulkWriteOptions.isOrdered:()Z
invokevirtual com.mongodb.client.model.BulkWriteOptions.ordered:(Z)Lcom/mongodb/client/model/BulkWriteOptions;
astore 6
start local 6 6: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 7
start local 7 7: aload 4
aload 5
aload 6
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.bulkWrite:(Ljava/util/List;Lcom/mongodb/client/model/BulkWriteOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 7
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
8: aload 7
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
io/vertx/ext/mongo/impl/Utils.toMongoClientBulkWriteResult(Lcom/mongodb/bulk/BulkWriteResult;)Lio/vertx/ext/mongo/MongoClientBulkWriteResult; (6)
(Lcom/mongodb/bulk/BulkWriteResult;)Lio/vertx/ext/mongo/MongoClientBulkWriteResult;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 7 end local 6 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 9 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 9 1 collection Ljava/lang/String;
0 9 2 operations Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;
0 9 3 bulkWriteOptions Lio/vertx/ext/mongo/BulkWriteOptions;
4 9 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
5 9 5 bulkOperations Ljava/util/List<Lcom/mongodb/client/model/WriteModel<Lio/vertx/core/json/JsonObject;>;>;
6 9 6 options Lcom/mongodb/client/model/BulkWriteOptions;
7 9 7 promise Lio/vertx/core/Promise<Lcom/mongodb/bulk/BulkWriteResult;>;
Signature: (Ljava/lang/String;Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;Lio/vertx/ext/mongo/BulkWriteOptions;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoClientBulkWriteResult;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
collection
operations
bulkWriteOptions
private java.util.List<com.mongodb.client.model.WriteModel<io.vertx.core.json.JsonObject>> convertBulkOperations(java.util.List<io.vertx.ext.mongo.BulkOperation>);
descriptor: (Ljava/util/List;)Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=9, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
aload 1
invokeinterface java.util.List.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 2
start local 2 1: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 27
StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.util.List java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.ext.mongo.BulkOperation
astore 3
start local 3 3: invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.$SWITCH_TABLE$io$vertx$ext$mongo$BulkOperation$BulkOperationType:()[I
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getType:()Lio/vertx/ext/mongo/BulkOperation$BulkOperationType;
invokevirtual io.vertx.ext.mongo.BulkOperation$BulkOperationType.ordinal:()I
iaload
tableswitch { // 1 - 4
1: 16
2: 12
3: 10
4: 4
default: 26
}
4: StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.util.List java.util.List io.vertx.ext.mongo.BulkOperation java.util.Iterator
StackMap stack:
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getFilter:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
astore 5
start local 5 5: aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.isMulti:()Z
ifeq 8
6: aload 2
new com.mongodb.client.model.DeleteManyModel
dup
aload 5
invokespecial com.mongodb.client.model.DeleteManyModel.<init>:(Lorg/bson/conversions/Bson;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
7: goto 27
8: StackMap locals: org.bson.conversions.Bson
StackMap stack:
aload 2
new com.mongodb.client.model.DeleteOneModel
dup
aload 5
invokespecial com.mongodb.client.model.DeleteOneModel.<init>:(Lorg/bson/conversions/Bson;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
9: goto 27
end local 5 10: StackMap locals:
StackMap stack:
aload 2
new com.mongodb.client.model.InsertOneModel
dup
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getDocument:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokespecial com.mongodb.client.model.InsertOneModel.<init>:(Ljava/lang/Object;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
11: goto 27
12: StackMap locals:
StackMap stack:
aload 2
new com.mongodb.client.model.ReplaceOneModel
dup
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getFilter:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getDocument:()Lio/vertx/core/json/JsonObject;
13: new com.mongodb.client.model.ReplaceOptions
dup
invokespecial com.mongodb.client.model.ReplaceOptions.<init>:()V
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.isUpsert:()Z
invokevirtual com.mongodb.client.model.ReplaceOptions.upsert:(Z)Lcom/mongodb/client/model/ReplaceOptions;
invokespecial com.mongodb.client.model.ReplaceOneModel.<init>:(Lorg/bson/conversions/Bson;Ljava/lang/Object;Lcom/mongodb/client/model/ReplaceOptions;)V
14: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: goto 27
16: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getFilter:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
astore 6
start local 6 17: aload 0
aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.getDocument:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
astore 7
start local 7 18: new com.mongodb.client.model.UpdateOptions
dup
invokespecial com.mongodb.client.model.UpdateOptions.<init>:()V
19: aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.isUpsert:()Z
invokevirtual com.mongodb.client.model.UpdateOptions.upsert:(Z)Lcom/mongodb/client/model/UpdateOptions;
20: astore 8
start local 8 21: aload 3
invokevirtual io.vertx.ext.mongo.BulkOperation.isMulti:()Z
ifeq 24
22: aload 2
new com.mongodb.client.model.UpdateManyModel
dup
aload 6
aload 7
aload 8
invokespecial com.mongodb.client.model.UpdateManyModel.<init>:(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
23: goto 27
24: StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.util.List java.util.List io.vertx.ext.mongo.BulkOperation java.util.Iterator top org.bson.conversions.Bson org.bson.conversions.Bson com.mongodb.client.model.UpdateOptions
StackMap stack:
aload 2
new com.mongodb.client.model.UpdateOneModel
dup
aload 6
aload 7
aload 8
invokespecial com.mongodb.client.model.UpdateOneModel.<init>:(Lorg/bson/conversions/Bson;Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/UpdateOptions;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
25: goto 27
end local 8 end local 7 end local 6 26: StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.util.List java.util.List io.vertx.ext.mongo.BulkOperation java.util.Iterator
StackMap stack:
new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Unknown bulk operation type: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
end local 3 27: StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
28: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 29 1 operations Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;
1 29 2 result Ljava/util/List<Lcom/mongodb/client/model/WriteModel<Lio/vertx/core/json/JsonObject;>;>;
3 27 3 bulkOperation Lio/vertx/ext/mongo/BulkOperation;
5 10 5 bsonFilter Lorg/bson/conversions/Bson;
17 26 6 filter Lorg/bson/conversions/Bson;
18 26 7 document Lorg/bson/conversions/Bson;
21 26 8 updateOptions Lcom/mongodb/client/model/UpdateOptions;
Signature: (Ljava/util/List<Lio/vertx/ext/mongo/BulkOperation;>;)Ljava/util/List<Lcom/mongodb/client/model/WriteModel<Lio/vertx/core/json/JsonObject;>;>;
MethodParameters:
Name Flags
operations
public io.vertx.ext.mongo.MongoClient createCollection(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createCollection:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 3
aload 2
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collectionName Ljava/lang/String;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 3 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collectionName
resultHandler
public io.vertx.core.Future<java.lang.Void> createCollection(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "collectionName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
getfield io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.db:Lcom/mongodb/reactivestreams/client/MongoDatabase;
aload 1
invokeinterface com.mongodb.reactivestreams.client.MongoDatabase.createCollection:(Ljava/lang/String;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 2
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
3: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 4 1 collectionName Ljava/lang/String;
2 4 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
collectionName
public io.vertx.ext.mongo.MongoClient getCollections(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<java.lang.String>>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollections:()Lio/vertx/core/Future;
astore 2
start local 2 1: aload 2
aload 1
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Ljava/lang/String;>;>;>;
1 3 2 future Lio/vertx/core/Future<Ljava/util/List<Ljava/lang/String;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Ljava/lang/String;>;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
resultHandler
public io.vertx.core.Future<java.util.List<java.lang.String>> getCollections();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 1
start local 1 1: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
getfield io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.db:Lcom/mongodb/reactivestreams/client/MongoDatabase;
invokeinterface com.mongodb.reactivestreams.client.MongoDatabase.listCollectionNames:()Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.BufferingSubscriber
dup
aload 1
invokespecial io.vertx.ext.mongo.impl.BufferingSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
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/ext/mongo/impl/MongoClientImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/util/List<Ljava/lang/String;>;>;
Signature: ()Lio/vertx/core/Future<Ljava/util/List<Ljava/lang/String;>;>;
public io.vertx.ext.mongo.MongoClient dropCollection(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.dropCollection:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 3
aload 2
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 3 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
resultHandler
public io.vertx.core.Future<java.lang.Void> dropCollection(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 2
start local 2 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 3: aload 2
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.drop:()Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 3
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 5 1 collection Ljava/lang/String;
2 5 2 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
3 5 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
collection
public io.vertx.ext.mongo.MongoClient createIndex(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createIndex:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 key Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
key
resultHandler
public io.vertx.core.Future<java.lang.Void> createIndex(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
new io.vertx.ext.mongo.IndexOptions
dup
invokespecial io.vertx.ext.mongo.IndexOptions.<init>:()V
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createIndexWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/IndexOptions;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 key Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
collection
key
public io.vertx.ext.mongo.MongoClient createIndexWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.IndexOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/IndexOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createIndexWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/IndexOptions;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 key Lio/vertx/core/json/JsonObject;
0 3 3 options Lio/vertx/ext/mongo/IndexOptions;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 5 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/IndexOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
key
options
resultHandler
public io.vertx.core.Future<java.lang.Void> createIndexWithOptions(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.IndexOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/IndexOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "fieldName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 3: aload 0
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.mongoIndexOptions:(Lio/vertx/ext/mongo/IndexOptions;)Lcom/mongodb/client/model/IndexOptions;
astore 5
start local 5 4: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 6
start local 6 5: aload 4
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
aload 5
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.createIndex:(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/IndexOptions;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 6
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
6: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 6 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 7 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 7 1 collection Ljava/lang/String;
0 7 2 key Lio/vertx/core/json/JsonObject;
0 7 3 options Lio/vertx/ext/mongo/IndexOptions;
3 7 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
4 7 5 driverOpts Lcom/mongodb/client/model/IndexOptions;
5 7 6 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/IndexOptions;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
collection
key
options
public io.vertx.ext.mongo.MongoClient createIndexes(java.lang.String, java.util.List<io.vertx.ext.mongo.IndexModel>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Ljava/util/List;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createIndexes:(Ljava/lang/String;Ljava/util/List;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 indexes Ljava/util/List<Lio/vertx/ext/mongo/IndexModel;>;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Ljava/util/List<Lio/vertx/ext/mongo/IndexModel;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
indexes
resultHandler
public io.vertx.core.Future<java.lang.Void> createIndexes(java.lang.String, java.util.List<io.vertx.ext.mongo.IndexModel>);
descriptor: (Ljava/lang/String;Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 0
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoClientImpl;)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/ext/mongo/impl/MongoClientImpl.lambda$11(Lio/vertx/ext/mongo/IndexModel;)Lcom/mongodb/client/model/IndexModel; (7)
(Lio/vertx/ext/mongo/IndexModel;)Lcom/mongodb/client/model/IndexModel;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
2: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
3: astore 3
start local 3 4: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 5: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
aload 3
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.createIndexes:(Ljava/util/List;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 4
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
6: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 7 1 collection Ljava/lang/String;
0 7 2 indexes Ljava/util/List<Lio/vertx/ext/mongo/IndexModel;>;
4 7 3 transformIndexes Ljava/util/List<Lcom/mongodb/client/model/IndexModel;>;
5 7 4 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Ljava/util/List<Lio/vertx/ext/mongo/IndexModel;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
collection
indexes
private static org.bson.conversions.Bson toBson(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
ifnonnull 1
aconst_null
goto 2
StackMap locals:
StackMap stack:
1: aload 0
invokevirtual io.vertx.core.json.JsonObject.encode:()Ljava/lang/String;
invokestatic org.bson.BsonDocument.parse:(Ljava/lang/String;)Lorg/bson/BsonDocument;
StackMap locals:
StackMap stack: org.bson.BsonDocument
2: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 json Lio/vertx/core/json/JsonObject;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
json
public io.vertx.ext.mongo.MongoClient listIndexes(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.listIndexes:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 3
aload 2
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonArray;>;>;
1 3 3 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonArray;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonArray;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonArray> listIndexes(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 2
start local 2 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 3: aload 2
ldc Lio/vertx/core/json/JsonObject;
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.listIndexes:(Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/ListIndexesPublisher;
new io.vertx.ext.mongo.impl.BufferingSubscriber
dup
aload 3
invokespecial io.vertx.ext.mongo.impl.BufferingSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.ListIndexesPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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;
io/vertx/core/json/JsonArray.<init>(Ljava/util/List;)V (8)
(Ljava/util/List;)Lio/vertx/core/json/JsonArray;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 5 1 collection Ljava/lang/String;
2 5 2 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
3 5 3 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/json/JsonObject;>;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonArray;>;
MethodParameters:
Name Flags
collection
public io.vertx.ext.mongo.MongoClient dropIndex(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.dropIndex:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 indexName Ljava/lang/String;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 4 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
indexName
resultHandler
public io.vertx.core.Future<java.lang.Void> dropIndex(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "indexName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 3
start local 3 3: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 4: aload 3
aload 2
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.dropIndex:(Ljava/lang/String;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 4
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
5: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 6 1 collection Ljava/lang/String;
0 6 2 indexName Ljava/lang/String;
3 6 3 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
4 6 4 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
collection
indexName
public io.vertx.ext.mongo.MongoClient runCommand(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.runCommand:(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 4
aload 3
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 commandName Ljava/lang/String;
0 3 2 command Lio/vertx/core/json/JsonObject;
0 3 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;
1 3 4 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
commandName
command
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonObject> runCommand(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "commandName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "command cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 3
start local 3 3: aload 2
aload 1
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
astore 4
start local 4 4: aload 4
ifnonnull 6
5: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "commandBody does not contain key for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals: io.vertx.core.json.JsonObject java.lang.Object
StackMap stack:
aload 3
aload 1
aload 4
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
7: aload 2
aload 1
aload 3
invokedynamic accept(Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Ljava/util/function/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
io/vertx/ext/mongo/impl/MongoClientImpl.lambda$13(Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokevirtual io.vertx.core.json.JsonObject.forEach:(Ljava/util/function/Consumer;)V
8: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 5
start local 5 9: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
getfield io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.db:Lcom/mongodb/reactivestreams/client/MongoDatabase;
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
ldc Lio/vertx/core/json/JsonObject;
invokeinterface com.mongodb.reactivestreams.client.MongoDatabase.runCommand:(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 5
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface org.reactivestreams.Publisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
10: aload 5
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
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 11 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 11 1 commandName Ljava/lang/String;
0 11 2 command Lio/vertx/core/json/JsonObject;
3 11 3 json Lio/vertx/core/json/JsonObject;
4 11 4 commandVal Ljava/lang/Object;
9 11 5 promise Lio/vertx/core/Promise<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_RETURN, location=[TYPE_ARGUMENT(0)]
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
commandName
command
public io.vertx.ext.mongo.MongoClient distinct(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.distinct:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 5
aload 4
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 fieldName Ljava/lang/String;
0 3 3 resultClassname Ljava/lang/String;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonArray;>;>;
1 3 5 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonArray;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonArray;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonArray> distinct(java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.distinctWithQuery:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 fieldName Ljava/lang/String;
0 1 3 resultClassname Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonArray;>;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
public io.vertx.ext.mongo.MongoClient distinctWithQuery(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonArray>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.distinctWithQuery:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
astore 6
start local 6 1: aload 6
aload 5
invokestatic io.vertx.ext.mongo.impl.Utils.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 6 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 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 collection Ljava/lang/String;
0 3 2 fieldName Ljava/lang/String;
0 3 3 resultClassname Ljava/lang/String;
0 3 4 query Lio/vertx/core/json/JsonObject;
0 3 5 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonArray;>;>;
1 3 6 future Lio/vertx/core/Future<Lio/vertx/core/json/JsonArray;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonArray;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
query
resultHandler
public io.vertx.core.Future<io.vertx.core.json.JsonArray> distinctWithQuery(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 5
start local 5 1: aload 0
aload 1
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findDistinctValuesWithQuery:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;
new io.vertx.ext.mongo.impl.BufferingSubscriber
dup
aload 5
invokespecial io.vertx.ext.mongo.impl.BufferingSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.DistinctPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
2: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
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;
io/vertx/core/json/JsonArray.<init>(Ljava/util/List;)V (8)
(Ljava/util/List;)Lio/vertx/core/json/JsonArray;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
3: areturn
end local 5 4: StackMap locals:
StackMap stack: java.lang.ClassNotFoundException
astore 5
start local 5 5: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 5
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
areturn
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 6 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 6 1 collection Ljava/lang/String;
0 6 2 fieldName Ljava/lang/String;
0 6 3 resultClassname Ljava/lang/String;
0 6 4 query Lio/vertx/core/json/JsonObject;
1 4 5 promise Lio/vertx/core/impl/future/PromiseInternal<Ljava/util/List<Ljava/lang/Object;>;>;
5 6 5 e Ljava/lang/ClassNotFoundException;
Exception table:
from to target type
0 3 4 Class java.lang.ClassNotFoundException
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Lio/vertx/core/json/JsonArray;>;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
query
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> distinctBatch(java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.distinctBatchWithQuery:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/streams/ReadStream;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 fieldName Ljava/lang/String;
0 1 3 resultClassname Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> distinctBatchWithQuery(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
aload 4
bipush 20
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.distinctBatchWithQuery:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;I)Lio/vertx/core/streams/ReadStream;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 fieldName Ljava/lang/String;
0 1 3 resultClassname Ljava/lang/String;
0 1 4 query Lio/vertx/core/json/JsonObject;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
query
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> distinctBatchWithQuery(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;I)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.findDistinctValuesWithQuery:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;
astore 6
start local 6 1: new io.vertx.ext.mongo.impl.PublisherAdapter
dup
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 6
iload 5
invokespecial io.vertx.ext.mongo.impl.PublisherAdapter.<init>:(Lio/vertx/core/impl/ContextInternal;Lorg/reactivestreams/Publisher;I)V
astore 7
start local 7 2: new io.vertx.ext.mongo.impl.MappingStream
dup
aload 7
aload 2
invokedynamic apply(Ljava/lang/String;)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/ext/mongo/impl/MongoClientImpl.lambda$15(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject; (6)
(Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
invokespecial io.vertx.ext.mongo.impl.MappingStream.<init>:(Lio/vertx/core/streams/ReadStream;Ljava/util/function/Function;)V
3: areturn
end local 7 end local 6 4: StackMap locals:
StackMap stack: java.lang.ClassNotFoundException
astore 6
start local 6 5: new io.vertx.ext.mongo.impl.FailedStream
dup
aload 6
invokespecial io.vertx.ext.mongo.impl.FailedStream.<init>:(Ljava/lang/ClassNotFoundException;)V
areturn
end local 6 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 6 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 6 1 collection Ljava/lang/String;
0 6 2 fieldName Ljava/lang/String;
0 6 3 resultClassname Ljava/lang/String;
0 6 4 query Lio/vertx/core/json/JsonObject;
0 6 5 batchSize I
1 4 6 distinctValuesWithQuery Lcom/mongodb/reactivestreams/client/DistinctPublisher<*>;
2 4 7 readStream Lio/vertx/ext/mongo/impl/PublisherAdapter<*>;
5 6 6 e Ljava/lang/ClassNotFoundException;
Exception table:
from to target type
0 3 4 Class java.lang.ClassNotFoundException
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;I)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
query
batchSize
public io.vertx.ext.mongo.MongoClient createDefaultGridFsBucketService(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoGridFsClient>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "fs"
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createGridFsBucketService:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoGridFsClient;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoGridFsClient;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoGridFsClient> createDefaultGridFsBucketService();
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.ext.mongo.impl.MongoClientImpl.createDefaultGridFsBucketService:(Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
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/ext/mongo/impl/MongoClientImpl;
1 3 1 promise Lio/vertx/core/Promise<Lio/vertx/ext/mongo/MongoGridFsClient;>;
Signature: ()Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoGridFsClient;>;
public io.vertx.ext.mongo.MongoClient createGridFsBucketService(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.mongo.MongoGridFsClient>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.ext.mongo.impl.MongoGridFsClientImpl
dup
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getGridFSBucket:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
invokespecial io.vertx.ext.mongo.impl.MongoGridFsClientImpl.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/vertx/ext/mongo/impl/MongoClientImpl;Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;)V
astore 3
start local 3 1: aload 2
aload 3
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 bucketName Ljava/lang/String;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoGridFsClient;>;>;
1 3 3 impl Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/mongo/MongoGridFsClient;>;>;)Lio/vertx/ext/mongo/MongoClient;
MethodParameters:
Name Flags
bucketName
resultHandler
public io.vertx.core.Future<io.vertx.ext.mongo.MongoGridFsClient> createGridFsBucketService(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.createGridFsBucketService:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoClient;
pop
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 bucketName Ljava/lang/String;
1 3 2 promise Lio/vertx/core/Promise<Lio/vertx/ext/mongo/MongoGridFsClient;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/ext/mongo/MongoGridFsClient;>;
MethodParameters:
Name Flags
bucketName
private com.mongodb.reactivestreams.client.gridfs.GridFSBucket getGridFSBucket(java.lang.String);
descriptor: (Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
getfield io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.db:Lcom/mongodb/reactivestreams/client/MongoDatabase;
aload 1
invokestatic com.mongodb.reactivestreams.client.gridfs.GridFSBuckets.create:(Lcom/mongodb/reactivestreams/client/MongoDatabase;Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 bucketName Ljava/lang/String;
MethodParameters:
Name Flags
bucketName
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> aggregate(java.lang.String, io.vertx.core.json.JsonArray);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonArray;)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
getstatic io.vertx.ext.mongo.impl.MongoClientImpl.DEFAULT_AGGREGATE_OPTIONS:Lio/vertx/ext/mongo/AggregateOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.aggregateWithOptions:(Ljava/lang/String;Lio/vertx/core/json/JsonArray;Lio/vertx/ext/mongo/AggregateOptions;)Lio/vertx/core/streams/ReadStream;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 collection Ljava/lang/String;
0 1 2 pipeline Lio/vertx/core/json/JsonArray;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonArray;)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection final
pipeline final
public io.vertx.core.streams.ReadStream<io.vertx.core.json.JsonObject> aggregateWithOptions(java.lang.String, io.vertx.core.json.JsonArray, io.vertx.ext.mongo.AggregateOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonArray;Lio/vertx/ext/mongo/AggregateOptions;)Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.doAggregate:(Ljava/lang/String;Lio/vertx/core/json/JsonArray;Lio/vertx/ext/mongo/AggregateOptions;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;
astore 4
start local 4 1: new io.vertx.ext.mongo.impl.PublisherAdapter
dup
aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 4
aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getBatchSize:()I
invokespecial io.vertx.ext.mongo.impl.PublisherAdapter.<init>:(Lio/vertx/core/impl/ContextInternal;Lorg/reactivestreams/Publisher;I)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 2 1 collection Ljava/lang/String;
0 2 2 pipeline Lio/vertx/core/json/JsonArray;
0 2 3 options Lio/vertx/ext/mongo/AggregateOptions;
1 2 4 view Lcom/mongodb/reactivestreams/client/AggregatePublisher<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonArray;Lio/vertx/ext/mongo/AggregateOptions;)Lio/vertx/core/streams/ReadStream<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection final
pipeline final
options final
private com.mongodb.reactivestreams.client.DistinctPublisher<?> findDistinctValuesWithQuery(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "fieldName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 4
ldc "query cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 4
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 5
start local 5 4: aload 0
aload 5
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 6
start local 6 5: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 7
start local 7 6: aload 0
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
aload 3
invokevirtual java.lang.ClassLoader.loadClass:(Ljava/lang/String;)Ljava/lang/Class;
astore 8
start local 8 7: aload 7
aload 2
aload 6
aload 8
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.distinct:(Ljava/lang/String;Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/DistinctPublisher;
areturn
end local 8 end local 7 end local 6 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 8 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 8 1 collection Ljava/lang/String;
0 8 2 fieldName Ljava/lang/String;
0 8 3 resultClassname Ljava/lang/String;
0 8 4 query Lio/vertx/core/json/JsonObject;
4 8 5 encodedQuery Lio/vertx/core/json/JsonObject;
5 8 6 bquery Lorg/bson/conversions/Bson;
6 8 7 mongoCollection Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
7 8 8 resultClass Ljava/lang/Class<*>;
Exceptions:
throws java.lang.ClassNotFoundException
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lcom/mongodb/reactivestreams/client/DistinctPublisher<*>;
MethodParameters:
Name Flags
collection
fieldName
resultClassname
query
private com.mongodb.reactivestreams.client.AggregatePublisher<io.vertx.core.json.JsonObject> doAggregate(java.lang.String, io.vertx.core.json.JsonArray, io.vertx.ext.mongo.AggregateOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonArray;Lio/vertx/ext/mongo/AggregateOptions;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "collection cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "pipeline cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 3
ldc "aggregateOptions cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 4: new java.util.ArrayList
dup
aload 2
invokevirtual io.vertx.core.json.JsonArray.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 5
start local 5 5: aload 2
invokevirtual io.vertx.core.json.JsonArray.getList:()Ljava/util/List;
aload 0
aload 5
invokedynamic accept(Lio/vertx/ext/mongo/impl/MongoClientImpl;Ljava/util/List;)Ljava/util/function/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
io/vertx/ext/mongo/impl/MongoClientImpl.lambda$16(Ljava/util/List;Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
6: aload 4
aload 5
ldc Lio/vertx/core/json/JsonObject;
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.aggregate:(Ljava/util/List;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;
astore 6
start local 6 7: aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getBatchSize:()I
iconst_m1
if_icmpeq 9
8: aload 6
aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getBatchSize:()I
invokeinterface com.mongodb.reactivestreams.client.AggregatePublisher.batchSize:(I)Lcom/mongodb/reactivestreams/client/AggregatePublisher;
pop
9: StackMap locals: com.mongodb.reactivestreams.client.MongoCollection java.util.List com.mongodb.reactivestreams.client.AggregatePublisher
StackMap stack:
aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getMaxTime:()J
lconst_0
lcmp
ifle 11
10: aload 6
aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getMaxTime:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface com.mongodb.reactivestreams.client.AggregatePublisher.maxTime:(JLjava/util/concurrent/TimeUnit;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;
pop
11: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getAllowDiskUse:()Ljava/lang/Boolean;
ifnull 13
12: aload 6
aload 3
invokevirtual io.vertx.ext.mongo.AggregateOptions.getAllowDiskUse:()Ljava/lang/Boolean;
invokeinterface com.mongodb.reactivestreams.client.AggregatePublisher.allowDiskUse:(Ljava/lang/Boolean;)Lcom/mongodb/reactivestreams/client/AggregatePublisher;
pop
13: StackMap locals:
StackMap stack:
aload 6
areturn
end local 6 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/ext/mongo/impl/MongoClientImpl;
0 14 1 collection Ljava/lang/String;
0 14 2 pipeline Lio/vertx/core/json/JsonArray;
0 14 3 aggregateOptions Lio/vertx/ext/mongo/AggregateOptions;
4 14 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
5 14 5 bpipeline Ljava/util/List<Lorg/bson/conversions/Bson;>;
7 14 6 aggregate Lcom/mongodb/reactivestreams/client/AggregatePublisher<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonArray;Lio/vertx/ext/mongo/AggregateOptions;)Lcom/mongodb/reactivestreams/client/AggregatePublisher<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection final
pipeline final
aggregateOptions final
io.vertx.core.json.JsonObject encodeKeyWhenUseObjectId(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
flags: (0x0000)
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.useObjectId:Z
ifne 1
aload 1
areturn
1: StackMap locals:
StackMap stack:
aload 1
ldc "_id"
aconst_null
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 2
start local 2 2: aload 2
instanceof java.lang.String
ifeq 4
aload 2
checkcast java.lang.String
invokestatic org.bson.types.ObjectId.isValid:(Ljava/lang/String;)Z
ifeq 4
3: aload 1
ldc "_id"
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
ldc "$oid"
aload 2
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
4: StackMap locals: java.lang.Object
StackMap stack:
aload 1
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 5 1 json Lio/vertx/core/json/JsonObject;
2 5 2 idString Ljava/lang/Object;
MethodParameters:
Name Flags
json
private io.vertx.core.json.JsonObject decodeKeyWhenUseObjectId(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.useObjectId:Z
ifne 1
aload 1
areturn
1: StackMap locals:
StackMap stack:
aload 1
ldc "_id"
aconst_null
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 2
start local 2 2: aload 2
instanceof io.vertx.core.json.JsonObject
ifne 3
aload 1
areturn
3: StackMap locals: java.lang.Object
StackMap stack:
aload 2
checkcast io.vertx.core.json.JsonObject
ldc "$oid"
aconst_null
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
astore 3
start local 3 4: aload 3
instanceof java.lang.String
ifne 5
aload 1
areturn
5: StackMap locals: java.lang.Object
StackMap stack:
aload 1
ldc "_id"
aload 3
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
6: aload 1
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 7 1 json Lio/vertx/core/json/JsonObject;
2 7 2 idField Ljava/lang/Object;
4 7 3 idString Ljava/lang/Object;
MethodParameters:
Name Flags
json
private com.mongodb.reactivestreams.client.FindPublisher<io.vertx.core.json.JsonObject> doFind(java.lang.String, io.vertx.core.json.JsonObject, io.vertx.ext.mongo.FindOptions);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lcom/mongodb/reactivestreams/client/FindPublisher;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 4
start local 4 1: aload 0
aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
astore 5
start local 5 2: aload 4
aload 5
ldc Lio/vertx/core/json/JsonObject;
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.find:(Lorg/bson/conversions/Bson;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/FindPublisher;
astore 6
start local 6 3: aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getLimit:()I
iconst_m1
if_icmpeq 5
4: aload 6
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getLimit:()I
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.limit:(I)Lcom/mongodb/reactivestreams/client/FindPublisher;
pop
5: StackMap locals: com.mongodb.reactivestreams.client.MongoCollection org.bson.conversions.Bson com.mongodb.reactivestreams.client.FindPublisher
StackMap stack:
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getSkip:()I
ifle 7
6: aload 6
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getSkip:()I
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.skip:(I)Lcom/mongodb/reactivestreams/client/FindPublisher;
pop
7: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getSort:()Lio/vertx/core/json/JsonObject;
ifnull 9
8: aload 6
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getSort:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.sort:(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;
pop
9: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getFields:()Lio/vertx/core/json/JsonObject;
ifnull 11
10: aload 6
aload 0
aload 3
invokevirtual io.vertx.ext.mongo.FindOptions.getFields:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokeinterface com.mongodb.reactivestreams.client.FindPublisher.projection:(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/FindPublisher;
pop
11: StackMap locals:
StackMap stack:
aload 6
areturn
end local 6 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 12 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 12 1 collection Ljava/lang/String;
0 12 2 query Lio/vertx/core/json/JsonObject;
0 12 3 options Lio/vertx/ext/mongo/FindOptions;
1 12 4 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
2 12 5 bquery Lorg/bson/conversions/Bson;
3 12 6 find Lcom/mongodb/reactivestreams/client/FindPublisher<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Lio/vertx/ext/mongo/FindOptions;)Lcom/mongodb/reactivestreams/client/FindPublisher<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
collection
query
options
private com.mongodb.reactivestreams.client.MongoCollection<io.vertx.core.json.JsonObject> getCollection(java.lang.String);
descriptor: (Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.getCollection:(Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 1 name Ljava/lang/String;
Signature: (Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
MethodParameters:
Name Flags
name
private com.mongodb.reactivestreams.client.MongoCollection<io.vertx.core.json.JsonObject> getCollection(java.lang.String, io.vertx.ext.mongo.WriteOption);
descriptor: (Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.holder:Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
getfield io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.db:Lcom/mongodb/reactivestreams/client/MongoDatabase;
aload 1
ldc Lio/vertx/core/json/JsonObject;
invokeinterface com.mongodb.reactivestreams.client.MongoDatabase.getCollection:(Ljava/lang/String;Ljava/lang/Class;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 3
start local 3 1: aload 3
ifnull 3
aload 2
ifnull 3
2: aload 3
aload 2
invokevirtual io.vertx.ext.mongo.WriteOption.name:()Ljava/lang/String;
invokestatic com.mongodb.WriteConcern.valueOf:(Ljava/lang/String;)Lcom/mongodb/WriteConcern;
invokeinterface com.mongodb.reactivestreams.client.MongoCollection.withWriteConcern:(Lcom/mongodb/WriteConcern;)Lcom/mongodb/reactivestreams/client/MongoCollection;
astore 3
3: StackMap locals: com.mongodb.reactivestreams.client.MongoCollection
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 4 1 name Ljava/lang/String;
0 4 2 writeOption Lio/vertx/ext/mongo/WriteOption;
1 4 3 coll Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
Signature: (Ljava/lang/String;Lio/vertx/ext/mongo/WriteOption;)Lcom/mongodb/reactivestreams/client/MongoCollection<Lio/vertx/core/json/JsonObject;>;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
name
writeOption
private com.mongodb.client.model.IndexOptions mongoIndexOptions(io.vertx.ext.mongo.IndexOptions);
descriptor: (Lio/vertx/ext/mongo/IndexOptions;)Lcom/mongodb/client/model/IndexOptions;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: new com.mongodb.client.model.IndexOptions
dup
invokespecial com.mongodb.client.model.IndexOptions.<init>:()V
1: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.isBackground:()Z
invokevirtual com.mongodb.client.model.IndexOptions.background:(Z)Lcom/mongodb/client/model/IndexOptions;
2: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.isUnique:()Z
invokevirtual com.mongodb.client.model.IndexOptions.unique:(Z)Lcom/mongodb/client/model/IndexOptions;
3: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getName:()Ljava/lang/String;
invokevirtual com.mongodb.client.model.IndexOptions.name:(Ljava/lang/String;)Lcom/mongodb/client/model/IndexOptions;
4: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.isSparse:()Z
invokevirtual com.mongodb.client.model.IndexOptions.sparse:(Z)Lcom/mongodb/client/model/IndexOptions;
5: aload 1
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual io.vertx.ext.mongo.IndexOptions.getExpireAfter:(Ljava/util/concurrent/TimeUnit;)Ljava/lang/Long;
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual com.mongodb.client.model.IndexOptions.expireAfter:(Ljava/lang/Long;Ljava/util/concurrent/TimeUnit;)Lcom/mongodb/client/model/IndexOptions;
6: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getVersion:()Ljava/lang/Integer;
invokevirtual com.mongodb.client.model.IndexOptions.version:(Ljava/lang/Integer;)Lcom/mongodb/client/model/IndexOptions;
7: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getWeights:()Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
invokevirtual com.mongodb.client.model.IndexOptions.weights:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/IndexOptions;
8: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getDefaultLanguage:()Ljava/lang/String;
invokevirtual com.mongodb.client.model.IndexOptions.defaultLanguage:(Ljava/lang/String;)Lcom/mongodb/client/model/IndexOptions;
9: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getLanguageOverride:()Ljava/lang/String;
invokevirtual com.mongodb.client.model.IndexOptions.languageOverride:(Ljava/lang/String;)Lcom/mongodb/client/model/IndexOptions;
10: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getTextVersion:()Ljava/lang/Integer;
invokevirtual com.mongodb.client.model.IndexOptions.textVersion:(Ljava/lang/Integer;)Lcom/mongodb/client/model/IndexOptions;
11: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getSphereVersion:()Ljava/lang/Integer;
invokevirtual com.mongodb.client.model.IndexOptions.sphereVersion:(Ljava/lang/Integer;)Lcom/mongodb/client/model/IndexOptions;
12: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getBits:()Ljava/lang/Integer;
invokevirtual com.mongodb.client.model.IndexOptions.bits:(Ljava/lang/Integer;)Lcom/mongodb/client/model/IndexOptions;
13: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getMin:()Ljava/lang/Double;
invokevirtual com.mongodb.client.model.IndexOptions.min:(Ljava/lang/Double;)Lcom/mongodb/client/model/IndexOptions;
14: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getMax:()Ljava/lang/Double;
invokevirtual com.mongodb.client.model.IndexOptions.max:(Ljava/lang/Double;)Lcom/mongodb/client/model/IndexOptions;
15: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getBucketSize:()Ljava/lang/Double;
invokevirtual com.mongodb.client.model.IndexOptions.bucketSize:(Ljava/lang/Double;)Lcom/mongodb/client/model/IndexOptions;
16: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getStorageEngine:()Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
invokevirtual com.mongodb.client.model.IndexOptions.storageEngine:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/IndexOptions;
17: aload 1
invokevirtual io.vertx.ext.mongo.IndexOptions.getPartialFilterExpression:()Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.ext.mongo.impl.MongoClientImpl.toBson:(Lio/vertx/core/json/JsonObject;)Lorg/bson/conversions/Bson;
invokevirtual com.mongodb.client.model.IndexOptions.partialFilterExpression:(Lorg/bson/conversions/Bson;)Lcom/mongodb/client/model/IndexOptions;
18: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 19 1 options Lio/vertx/ext/mongo/IndexOptions;
MethodParameters:
Name Flags
options
io.vertx.ext.mongo.impl.JsonObjectBsonAdapter wrap(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 1
aconst_null
goto 2
StackMap locals:
StackMap stack:
1: new io.vertx.ext.mongo.impl.JsonObjectBsonAdapter
dup
aload 1
invokespecial io.vertx.ext.mongo.impl.JsonObjectBsonAdapter.<init>:(Lio/vertx/core/json/JsonObject;)V
StackMap locals:
StackMap stack: io.vertx.ext.mongo.impl.JsonObjectBsonAdapter
2: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 jsonObject Lio/vertx/core/json/JsonObject;
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
io.vertx.codegen.annotations.Nullable()
METHOD_RETURN
io.vertx.codegen.annotations.Nullable()
MethodParameters:
Name Flags
jsonObject
private void removeFromMap(io.vertx.core.shareddata.LocalMap<java.lang.String, io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder>, java.lang.String);
descriptor: (Lio/vertx/core/shareddata/LocalMap;Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
dup
astore 3
monitorenter
1: aload 1
aload 2
invokeinterface io.vertx.core.shareddata.LocalMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 1
invokeinterface io.vertx.core.shareddata.LocalMap.isEmpty:()Z
ifeq 4
3: aload 1
invokeinterface io.vertx.core.shareddata.LocalMap.close:()V
4: StackMap locals: io.vertx.core.impl.VertxInternal
StackMap stack:
aload 3
monitorexit
5: goto 8
StackMap locals:
StackMap stack: java.lang.Throwable
6: aload 3
monitorexit
7: athrow
8: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 9 1 map Lio/vertx/core/shareddata/LocalMap<Ljava/lang/String;Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;>;
0 9 2 dataSourceName Ljava/lang/String;
Exception table:
from to target type
1 5 6 any
6 7 6 any
Signature: (Lio/vertx/core/shareddata/LocalMap<Ljava/lang/String;Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;>;Ljava/lang/String;)V
MethodParameters:
Name Flags
map
dataSourceName
private io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder lookupHolder(java.lang.String, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.sharedData:()Lio/vertx/core/shareddata/SharedData;
ldc "__vertx.MongoClient.datasources"
invokeinterface io.vertx.core.shareddata.SharedData.getLocalMap:(Ljava/lang/String;)Lio/vertx/core/shareddata/LocalMap;
astore 4
start local 4 2: aload 4
aload 1
invokeinterface io.vertx.core.shareddata.LocalMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder
astore 5
start local 5 3: aload 5
ifnonnull 7
4: new io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder
dup
aload 2
aload 0
aload 4
aload 1
invokedynamic run(Lio/vertx/ext/mongo/impl/MongoClientImpl;Lio/vertx/core/shareddata/LocalMap;Ljava/lang/String;)Ljava/lang/Runnable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
io/vertx/ext/mongo/impl/MongoClientImpl.lambda$17(Lio/vertx/core/shareddata/LocalMap;Ljava/lang/String;)V (7)
()V
invokespecial io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.<init>:(Lio/vertx/core/json/JsonObject;Ljava/lang/Runnable;)V
astore 5
5: aload 4
aload 1
aload 5
invokeinterface io.vertx.core.shareddata.LocalMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: goto 8
7: StackMap locals: io.vertx.core.impl.VertxInternal io.vertx.core.shareddata.LocalMap io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder
StackMap stack:
aload 5
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder.incRefCount:()V
8: StackMap locals:
StackMap stack:
aload 5
aload 3
monitorexit
9: areturn
end local 5 end local 4 10: StackMap locals: io.vertx.ext.mongo.impl.MongoClientImpl java.lang.String io.vertx.core.json.JsonObject io.vertx.core.impl.VertxInternal
StackMap stack: java.lang.Throwable
aload 3
monitorexit
11: athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 12 1 datasourceName Ljava/lang/String;
0 12 2 config Lio/vertx/core/json/JsonObject;
2 10 4 map Lio/vertx/core/shareddata/LocalMap<Ljava/lang/String;Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;>;
3 10 5 theHolder Lio/vertx/ext/mongo/impl/MongoClientImpl$MongoHolder;
Exception table:
from to target type
1 9 10 any
10 11 10 any
MethodParameters:
Name Flags
datasourceName
config
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 2
start local 2 1: aload 0
aload 2
aload 1
invokeinterface io.vertx.core.impl.ContextInternal.promise:(Lio/vertx/core/Handler;)Lio/vertx/core/impl/future/PromiseInternal;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.close:(Lio/vertx/core/Promise;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 2 ctx Lio/vertx/core/impl/ContextInternal;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
static int[] $SWITCH_TABLE$io$vertx$ext$mongo$BulkOperation$BulkOperationType();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic io.vertx.ext.mongo.impl.MongoClientImpl.$SWITCH_TABLE$io$vertx$ext$mongo$BulkOperation$BulkOperationType:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic io.vertx.ext.mongo.BulkOperation$BulkOperationType.values:()[Lio/vertx/ext/mongo/BulkOperation$BulkOperationType;
arraylength
newarray 10
astore 0
2: aload 0
getstatic io.vertx.ext.mongo.BulkOperation$BulkOperationType.DELETE:Lio/vertx/ext/mongo/BulkOperation$BulkOperationType;
invokevirtual io.vertx.ext.mongo.BulkOperation$BulkOperationType.ordinal:()I
iconst_4
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic io.vertx.ext.mongo.BulkOperation$BulkOperationType.INSERT:Lio/vertx/ext/mongo/BulkOperation$BulkOperationType;
invokevirtual io.vertx.ext.mongo.BulkOperation$BulkOperationType.ordinal:()I
iconst_3
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic io.vertx.ext.mongo.BulkOperation$BulkOperationType.REPLACE:Lio/vertx/ext/mongo/BulkOperation$BulkOperationType;
invokevirtual io.vertx.ext.mongo.BulkOperation$BulkOperationType.ordinal:()I
iconst_2
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic io.vertx.ext.mongo.BulkOperation$BulkOperationType.UPDATE:Lio/vertx/ext/mongo/BulkOperation$BulkOperationType;
invokevirtual io.vertx.ext.mongo.BulkOperation$BulkOperationType.ordinal:()I
iconst_1
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
dup
putstatic io.vertx.ext.mongo.impl.MongoClientImpl.$SWITCH_TABLE$io$vertx$ext$mongo$BulkOperation$BulkOperationType:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
11 12 13 Class java.lang.NoSuchFieldError
private java.lang.String lambda$0(io.vertx.core.json.JsonObject, java.lang.Void);
descriptor: (Lio/vertx/core/json/JsonObject;Ljava/lang/Void;)Ljava/lang/String;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoClientImpl.useObjectId:Z
ifeq 1
aload 1
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.getJsonObject:(Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
ldc "$oid"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
goto 2
StackMap locals:
StackMap stack:
1: aload 1
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
StackMap locals:
StackMap stack: java.lang.String
2: areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 2 v Ljava/lang/Void;
private java.lang.String lambda$1(boolean, io.vertx.core.json.JsonObject, java.lang.Void);
descriptor: (ZLio/vertx/core/json/JsonObject;Ljava/lang/Void;)Ljava/lang/String;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 3 0: iload 1
ifeq 1
aconst_null
goto 2
StackMap locals:
StackMap stack:
1: aload 0
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.decodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
ldc "_id"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
StackMap locals:
StackMap stack: java.lang.String
2: areturn
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 3 v Ljava/lang/Void;
private void lambda$2(java.util.List, java.lang.Object);
descriptor: (Ljava/util/List;Ljava/lang/Object;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 1
aload 0
aload 2
invokestatic io.vertx.core.json.JsonObject.mapFrom:(Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 2 entry Ljava/lang/Object;
private io.vertx.core.json.JsonObject lambda$6(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 1
aconst_null
goto 2
StackMap locals:
StackMap stack:
1: aload 0
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.decodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
StackMap locals:
StackMap stack: io.vertx.core.json.JsonObject
2: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 object Lio/vertx/core/json/JsonObject;
private void lambda$7(java.util.List, java.lang.Object);
descriptor: (Ljava/util/List;Ljava/lang/Object;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 1
aload 0
aload 2
invokestatic io.vertx.core.json.JsonObject.mapFrom:(Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 2 entry Ljava/lang/Object;
private com.mongodb.client.model.IndexModel lambda$11(io.vertx.ext.mongo.IndexModel);
descriptor: (Lio/vertx/ext/mongo/IndexModel;)Lcom/mongodb/client/model/IndexModel;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.vertx.ext.mongo.IndexModel.getOptions:()Lio/vertx/ext/mongo/IndexOptions;
ifnull 2
1: new com.mongodb.client.model.IndexModel
dup
aload 0
aload 1
invokevirtual io.vertx.ext.mongo.IndexModel.getKey:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
aload 0
aload 1
invokevirtual io.vertx.ext.mongo.IndexModel.getOptions:()Lio/vertx/ext/mongo/IndexOptions;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.mongoIndexOptions:(Lio/vertx/ext/mongo/IndexOptions;)Lcom/mongodb/client/model/IndexOptions;
invokespecial com.mongodb.client.model.IndexModel.<init>:(Lorg/bson/conversions/Bson;Lcom/mongodb/client/model/IndexOptions;)V
areturn
2: StackMap locals:
StackMap stack:
new com.mongodb.client.model.IndexModel
dup
aload 0
aload 1
invokevirtual io.vertx.ext.mongo.IndexModel.getKey:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokespecial com.mongodb.client.model.IndexModel.<init>:(Lorg/bson/conversions/Bson;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 3 1 it Lio/vertx/ext/mongo/IndexModel;
private static void lambda$13(java.lang.String, io.vertx.core.json.JsonObject, java.util.Map$Entry);
descriptor: (Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 2
1: aload 1
aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 2
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
2: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Object;>;
private static io.vertx.core.json.JsonObject lambda$15(java.lang.String, java.lang.Object);
descriptor: (Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
aload 0
aload 1
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 value Ljava/lang/Object;
private void lambda$16(java.util.List, java.lang.Object);
descriptor: (Ljava/util/List;Ljava/lang/Object;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 1
aload 0
aload 2
invokestatic io.vertx.core.json.JsonObject.mapFrom:(Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.wrap:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/mongo/impl/JsonObjectBsonAdapter;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 1 2 entry Ljava/lang/Object;
private void lambda$17(io.vertx.core.shareddata.LocalMap, java.lang.String);
descriptor: (Lio/vertx/core/shareddata/LocalMap;Ljava/lang/String;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.removeFromMap:(Lio/vertx/core/shareddata/LocalMap;Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoClientImpl;
}
SourceFile: "MongoClientImpl.java"
NestMembers:
io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder
InnerClasses:
public final BulkOperationType = io.vertx.ext.mongo.BulkOperation$BulkOperationType of io.vertx.ext.mongo.BulkOperation
private MongoHolder = io.vertx.ext.mongo.impl.MongoClientImpl$MongoHolder of io.vertx.ext.mongo.impl.MongoClientImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map