public class io.vertx.ext.mongo.impl.MongoGridFsClientImpl implements io.vertx.ext.mongo.MongoGridFsClient
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.mongo.impl.MongoGridFsClientImpl
super_class: java.lang.Object
{
private final com.mongodb.reactivestreams.client.gridfs.GridFSBucket bucket;
descriptor: Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.ext.mongo.impl.MongoClientImpl clientImpl;
descriptor: Lio/vertx/ext/mongo/impl/MongoClientImpl;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(io.vertx.core.impl.VertxInternal, io.vertx.ext.mongo.impl.MongoClientImpl, com.mongodb.reactivestreams.client.gridfs.GridFSBucket);
descriptor: (Lio/vertx/core/impl/VertxInternal;Lio/vertx/ext/mongo/impl/MongoClientImpl;Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, 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 0
aload 1
putfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
2: aload 0
aload 2
putfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.clientImpl:Lio/vertx/ext/mongo/impl/MongoClientImpl;
3: aload 0
aload 3
putfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
4: return
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/MongoGridFsClientImpl;
0 5 1 vertx Lio/vertx/core/impl/VertxInternal;
0 5 2 mongoClient Lio/vertx/ext/mongo/impl/MongoClientImpl;
0 5 3 gridFSBucket Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
MethodParameters:
Name Flags
vertx
mongoClient
gridFSBucket
public io.vertx.ext.mongo.MongoGridFsClient uploadByFileName(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Lio/vertx/core/streams/ReadStream;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.uploadByFileName:(Lio/vertx/core/streams/ReadStream;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/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 fileName Ljava/lang/String;
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: (Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
stream
fileName
resultHandler
public io.vertx.core.Future<java.lang.String> uploadByFileName(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, java.lang.String);
descriptor: (Lio/vertx/core/streams/ReadStream;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: new io.vertx.ext.mongo.impl.GridFSReadStreamPublisher
dup
aload 1
invokespecial io.vertx.ext.mongo.impl.GridFSReadStreamPublisher.<init>:(Lio/vertx/core/streams/ReadStream;)V
astore 3
start local 3 1: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
aload 3
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.uploadFromPublisher:(Ljava/lang/String;Lorg/reactivestreams/Publisher;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSUploadPublisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 4
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSUploadPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
3: aload 4
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;
org/bson/types/ObjectId.toHexString()Ljava/lang/String; (5)
(Lorg/bson/types/ObjectId;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)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 4 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 4 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 4 2 fileName Ljava/lang/String;
1 4 3 publisher Lio/vertx/ext/mongo/impl/GridFSReadStreamPublisher;
2 4 4 promise Lio/vertx/core/Promise<Lorg/bson/types/ObjectId;>;
Signature: (Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
stream
fileName
public io.vertx.ext.mongo.MongoGridFsClient uploadByFileNameWithOptions(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.ext.mongo.GridFsUploadOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Lio/vertx/core/streams/ReadStream;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.uploadByFileNameWithOptions:(Lio/vertx/core/streams/ReadStream;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)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/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 fileName Ljava/lang/String;
0 3 3 options Lio/vertx/ext/mongo/GridFsUploadOptions;
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: (Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
stream
fileName
options
resultHandler
public io.vertx.core.Future<java.lang.String> uploadByFileNameWithOptions(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.ext.mongo.GridFsUploadOptions);
descriptor: (Lio/vertx/core/streams/ReadStream;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)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: new com.mongodb.client.gridfs.model.GridFSUploadOptions
dup
invokespecial com.mongodb.client.gridfs.model.GridFSUploadOptions.<init>:()V
astore 4
start local 4 1: aload 4
aload 3
invokevirtual io.vertx.ext.mongo.GridFsUploadOptions.getChunkSizeBytes:()Ljava/lang/Integer;
invokevirtual com.mongodb.client.gridfs.model.GridFSUploadOptions.chunkSizeBytes:(Ljava/lang/Integer;)Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;
pop
2: aload 3
invokevirtual io.vertx.ext.mongo.GridFsUploadOptions.getMetadata:()Lio/vertx/core/json/JsonObject;
ifnull 3
aload 4
new org.bson.Document
dup
aload 3
invokevirtual io.vertx.ext.mongo.GridFsUploadOptions.getMetadata:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.core.json.JsonObject.getMap:()Ljava/util/Map;
invokespecial org.bson.Document.<init>:(Ljava/util/Map;)V
invokevirtual com.mongodb.client.gridfs.model.GridFSUploadOptions.metadata:(Lorg/bson/Document;)Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;
pop
3: StackMap locals: com.mongodb.client.gridfs.model.GridFSUploadOptions
StackMap stack:
new io.vertx.ext.mongo.impl.GridFSReadStreamPublisher
dup
aload 1
invokespecial io.vertx.ext.mongo.impl.GridFSReadStreamPublisher.<init>:(Lio/vertx/core/streams/ReadStream;)V
astore 5
start local 5 4: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.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 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
aload 5
aload 4
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.uploadFromPublisher:(Ljava/lang/String;Lorg/reactivestreams/Publisher;Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSUploadPublisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 6
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSUploadPublisher.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;
org/bson/types/ObjectId.toHexString()Ljava/lang/String; (5)
(Lorg/bson/types/ObjectId;)Ljava/lang/String;
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/MongoGridFsClientImpl;
0 7 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 7 2 fileName Ljava/lang/String;
0 7 3 options Lio/vertx/ext/mongo/GridFsUploadOptions;
1 7 4 uploadOptions Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;
4 7 5 publisher Lio/vertx/ext/mongo/impl/GridFSReadStreamPublisher;
5 7 6 promise Lio/vertx/core/Promise<Lorg/bson/types/ObjectId;>;
Signature: (Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
stream
fileName
options
public io.vertx.ext.mongo.MongoGridFsClient uploadFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.uploadFile:(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/MongoGridFsClientImpl;
0 3 1 fileName Ljava/lang/String;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
1 3 3 future Lio/vertx/core/Future<Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
fileName
resultHandler
public io.vertx.core.Future<java.lang.String> uploadFile(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "fileName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aconst_null
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.uploadFileWithOptions:(Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 2 1 fileName Ljava/lang/String;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
fileName
public io.vertx.ext.mongo.MongoGridFsClient uploadFileWithOptions(java.lang.String, io.vertx.ext.mongo.GridFsUploadOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
descriptor: (Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.uploadFileWithOptions:(Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)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/MongoGridFsClientImpl;
0 3 1 fileName Ljava/lang/String;
0 3 2 options Lio/vertx/ext/mongo/GridFsUploadOptions;
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/ext/mongo/GridFsUploadOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
fileName
options
resultHandler
public io.vertx.core.Future<java.lang.String> uploadFileWithOptions(java.lang.String, io.vertx.ext.mongo.GridFsUploadOptions);
descriptor: (Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "fileName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.vertx.core.file.OpenOptions
dup
invokespecial io.vertx.core.file.OpenOptions.<init>:()V
iconst_1
invokevirtual io.vertx.core.file.OpenOptions.setRead:(Z)Lio/vertx/core/file/OpenOptions;
astore 3
start local 3 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.fileSystem:()Lio/vertx/core/file/FileSystem;
aload 1
aload 3
invokeinterface io.vertx.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;)Lio/vertx/core/Future;
3: aload 0
aload 2
aload 1
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;Lio/vertx/ext/mongo/GridFsUploadOptions;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/MongoGridFsClientImpl.lambda$2(Lio/vertx/ext/mongo/GridFsUploadOptions;Ljava/lang/String;Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future; (7)
(Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
4: 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/MongoGridFsClientImpl;
0 5 1 fileName Ljava/lang/String;
0 5 2 options Lio/vertx/ext/mongo/GridFsUploadOptions;
2 5 3 openOptions Lio/vertx/core/file/OpenOptions;
Signature: (Ljava/lang/String;Lio/vertx/ext/mongo/GridFsUploadOptions;)Lio/vertx/core/Future<Ljava/lang/String;>;
MethodParameters:
Name Flags
fileName
options
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
public io.vertx.ext.mongo.MongoGridFsClient delete(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/MongoGridFsClient;
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.MongoGridFsClientImpl.delete:(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/MongoGridFsClientImpl;
0 3 1 id 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/MongoGridFsClient;
MethodParameters:
Name Flags
id
resultHandler
public io.vertx.core.Future<java.lang.Void> delete(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 "id cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new org.bson.types.ObjectId
dup
aload 1
invokespecial org.bson.types.ObjectId.<init>:(Ljava/lang/String;)V
astore 2
start local 2 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.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 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.delete:(Lorg/bson/types/ObjectId;)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/MongoGridFsClientImpl;
0 5 1 id Ljava/lang/String;
2 5 2 objectId Lorg/bson/types/ObjectId;
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
id
public io.vertx.ext.mongo.MongoGridFsClient downloadByFileName(io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.downloadByFileName:(Lio/vertx/core/streams/WriteStream;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/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 fileName Ljava/lang/String;
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: (Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
stream
fileName
resultHandler
public io.vertx.core.Future<java.lang.Long> downloadByFileName(io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, java.lang.String);
descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
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.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.downloadToPublisher:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
astore 3
start local 3 1: aload 0
aload 3
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.handleDownload:(Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream;)Lio/vertx/core/Future;
areturn
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/MongoGridFsClientImpl;
0 2 1 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
0 2 2 fileName Ljava/lang/String;
1 2 3 publisher Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
Signature: (Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
stream
fileName
public io.vertx.ext.mongo.MongoGridFsClient downloadByFileNameWithOptions(io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.ext.mongo.GridFsDownloadOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsDownloadOptions;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.downloadByFileNameWithOptions:(Lio/vertx/core/streams/WriteStream;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsDownloadOptions;)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/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 fileName Ljava/lang/String;
0 3 3 options Lio/vertx/ext/mongo/GridFsDownloadOptions;
0 3 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;
1 3 5 future Lio/vertx/core/Future<Ljava/lang/Long;>;
Signature: (Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsDownloadOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
stream
fileName
options
resultHandler
public io.vertx.core.Future<java.lang.Long> downloadByFileNameWithOptions(io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.ext.mongo.GridFsDownloadOptions);
descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsDownloadOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new com.mongodb.client.gridfs.model.GridFSDownloadOptions
dup
invokespecial com.mongodb.client.gridfs.model.GridFSDownloadOptions.<init>:()V
astore 4
start local 4 1: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
aload 4
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.downloadToPublisher:(Ljava/lang/String;Lcom/mongodb/client/gridfs/model/GridFSDownloadOptions;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
astore 5
start local 5 2: aload 0
aload 5
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.handleDownload:(Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream;)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 3 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 fileName Ljava/lang/String;
0 3 3 options Lio/vertx/ext/mongo/GridFsDownloadOptions;
1 3 4 downloadOptions Lcom/mongodb/client/gridfs/model/GridFSDownloadOptions;
2 3 5 publisher Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
Signature: (Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/ext/mongo/GridFsDownloadOptions;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
stream
fileName
options
public io.vertx.ext.mongo.MongoGridFsClient downloadById(io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.downloadById:(Lio/vertx/core/streams/WriteStream;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/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 id Ljava/lang/String;
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: (Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
stream
id
resultHandler
public io.vertx.core.Future<java.lang.Long> downloadById(io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>, java.lang.String);
descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: new org.bson.types.ObjectId
dup
aload 2
invokespecial org.bson.types.ObjectId.<init>:(Ljava/lang/String;)V
astore 3
start local 3 1: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 3
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.downloadToPublisher:(Lorg/bson/types/ObjectId;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
astore 4
start local 4 2: aload 0
aload 4
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.handleDownload:(Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream;)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 3 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 3 1 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
0 3 2 id Ljava/lang/String;
1 3 3 objectId Lorg/bson/types/ObjectId;
2 3 4 publisher Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
Signature: (Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
stream
id
public io.vertx.ext.mongo.MongoGridFsClient downloadFile(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.downloadFile:(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/MongoGridFsClientImpl;
0 3 1 fileName Ljava/lang/String;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;
1 3 3 future Lio/vertx/core/Future<Ljava/lang/Long;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
fileName
resultHandler
public io.vertx.core.Future<java.lang.Long> downloadFile(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "fileName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.downloadFileAs:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 2 1 fileName Ljava/lang/String;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
fileName
public io.vertx.ext.mongo.MongoGridFsClient downloadFileAs(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.downloadFileAs:(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/MongoGridFsClientImpl;
0 3 1 fileName Ljava/lang/String;
0 3 2 newFileName Ljava/lang/String;
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;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
fileName
newFileName
resultHandler
public io.vertx.core.Future<java.lang.Long> downloadFileAs(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "fileName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
ldc "newFileName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.vertx.core.file.OpenOptions
dup
invokespecial io.vertx.core.file.OpenOptions.<init>:()V
iconst_1
invokevirtual io.vertx.core.file.OpenOptions.setWrite:(Z)Lio/vertx/core/file/OpenOptions;
astore 3
start local 3 3: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.fileSystem:()Lio/vertx/core/file/FileSystem;
aload 2
aload 3
invokeinterface io.vertx.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;)Lio/vertx/core/Future;
4: aload 0
aload 1
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;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/MongoGridFsClientImpl.lambda$4(Ljava/lang/String;Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future; (7)
(Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
5: areturn
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/MongoGridFsClientImpl;
0 6 1 fileName Ljava/lang/String;
0 6 2 newFileName Ljava/lang/String;
3 6 3 options Lio/vertx/core/file/OpenOptions;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
fileName
newFileName
public io.vertx.ext.mongo.MongoGridFsClient downloadFileByID(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.downloadFileByID:(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/MongoGridFsClientImpl;
0 3 1 id Ljava/lang/String;
0 3 2 fileName Ljava/lang/String;
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;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
id
fileName
resultHandler
public io.vertx.core.Future<java.lang.Long> downloadFileByID(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ldc "fileName cannot be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: new io.vertx.core.file.OpenOptions
dup
invokespecial io.vertx.core.file.OpenOptions.<init>:()V
iconst_1
invokevirtual io.vertx.core.file.OpenOptions.setWrite:(Z)Lio/vertx/core/file/OpenOptions;
astore 3
start local 3 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.fileSystem:()Lio/vertx/core/file/FileSystem;
aload 2
aload 3
invokeinterface io.vertx.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;)Lio/vertx/core/Future;
3: aload 0
aload 1
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;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/MongoGridFsClientImpl.lambda$5(Ljava/lang/String;Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future; (7)
(Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
4: 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/MongoGridFsClientImpl;
0 5 1 id Ljava/lang/String;
0 5 2 fileName Ljava/lang/String;
2 5 3 options Lio/vertx/core/file/OpenOptions;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
id
fileName
public io.vertx.ext.mongo.MongoGridFsClient drop(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.drop:()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/MongoGridFsClientImpl;
0 3 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 3 2 future Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
resultHandler
public io.vertx.core.Future<java.lang.Void> drop();
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.MongoGridFsClientImpl.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.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.drop:()Lorg/reactivestreams/Publisher;
new io.vertx.ext.mongo.impl.CompletionSubscriber
dup
aload 1
invokespecial io.vertx.ext.mongo.impl.CompletionSubscriber.<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/MongoGridFsClientImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.ext.mongo.MongoGridFsClient findAllIds(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<java.lang.String>>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.findAllIds:()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/MongoGridFsClientImpl;
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/MongoGridFsClient;
MethodParameters:
Name Flags
resultHandler
public io.vertx.core.Future<java.util.List<java.lang.String>> findAllIds();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.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.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.find:()Lcom/mongodb/reactivestreams/client/gridfs/GridFSFindPublisher;
new io.vertx.ext.mongo.impl.MappingAndBufferingSubscriber
dup
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/MongoGridFsClientImpl.lambda$6(Lcom/mongodb/client/gridfs/model/GridFSFile;)Ljava/lang/String; (6)
(Lcom/mongodb/client/gridfs/model/GridFSFile;)Ljava/lang/String;
aload 1
invokespecial io.vertx.ext.mongo.impl.MappingAndBufferingSubscriber.<init>:(Ljava/util/function/Function;Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher.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/MongoGridFsClientImpl;
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.MongoGridFsClient findIds(io.vertx.core.json.JsonObject, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<java.lang.String>>>);
descriptor: (Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)Lio/vertx/ext/mongo/MongoGridFsClient;
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.MongoGridFsClientImpl.findIds:(Lio/vertx/core/json/JsonObject;)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/MongoGridFsClientImpl;
0 3 1 query Lio/vertx/core/json/JsonObject;
0 3 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Ljava/lang/String;>;>;>;
1 3 3 future Lio/vertx/core/Future<Ljava/util/List<Ljava/lang/String;>;>;
Signature: (Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Ljava/lang/String;>;>;>;)Lio/vertx/ext/mongo/MongoGridFsClient;
MethodParameters:
Name Flags
query
resultHandler
public io.vertx.core.Future<java.util.List<java.lang.String>> findIds(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: aload 1
ldc "query 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.MongoGridFsClientImpl.clientImpl:Lio/vertx/ext/mongo/impl/MongoClientImpl;
aload 1
invokevirtual io.vertx.ext.mongo.impl.MongoClientImpl.encodeKeyWhenUseObjectId:(Lio/vertx/core/json/JsonObject;)Lio/vertx/core/json/JsonObject;
astore 2
start local 2 2: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.clientImpl:Lio/vertx/ext/mongo/impl/MongoClientImpl;
aload 2
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
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.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 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 3
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.find:(Lorg/bson/conversions/Bson;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSFindPublisher;
new io.vertx.ext.mongo.impl.MappingAndBufferingSubscriber
dup
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/MongoGridFsClientImpl.lambda$7(Lcom/mongodb/client/gridfs/model/GridFSFile;)Ljava/lang/String; (6)
(Lcom/mongodb/client/gridfs/model/GridFSFile;)Ljava/lang/String;
aload 4
invokespecial io.vertx.ext.mongo.impl.MappingAndBufferingSubscriber.<init>:(Ljava/util/function/Function;Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher.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/MongoGridFsClientImpl;
0 6 1 query Lio/vertx/core/json/JsonObject;
2 6 2 encodedQuery Lio/vertx/core/json/JsonObject;
3 6 3 bquery Lorg/bson/conversions/Bson;
4 6 4 promise Lio/vertx/core/Promise<Ljava/util/List<Ljava/lang/String;>;>;
Signature: (Lio/vertx/core/json/JsonObject;)Lio/vertx/core/Future<Ljava/util/List<Ljava/lang/String;>;>;
MethodParameters:
Name Flags
query
private io.vertx.core.Future<java.lang.Long> handleDownload(com.mongodb.reactivestreams.client.gridfs.GridFSDownloadPublisher, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>);
descriptor: (Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream;)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.ext.mongo.impl.PublisherAdapter
dup
aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 1
bipush 16
invokespecial io.vertx.ext.mongo.impl.PublisherAdapter.<init>:(Lio/vertx/core/impl/ContextInternal;Lorg/reactivestreams/Publisher;I)V
astore 3
start local 3 1: new io.vertx.ext.mongo.impl.MongoGridFsClientImpl$MapAndCountBuffer
dup
invokespecial io.vertx.ext.mongo.impl.MongoGridFsClientImpl$MapAndCountBuffer.<init>:()V
astore 4
start local 4 2: new io.vertx.ext.mongo.impl.MappingStream
dup
aload 3
aload 4
invokespecial io.vertx.ext.mongo.impl.MappingStream.<init>:(Lio/vertx/core/streams/ReadStream;Ljava/util/function/Function;)V
astore 5
start local 5 3: aload 5
aload 2
invokevirtual io.vertx.ext.mongo.impl.MappingStream.pipeTo:(Lio/vertx/core/streams/WriteStream;)Lio/vertx/core/Future;
aload 4
invokedynamic apply(Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl$MapAndCountBuffer;)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/MongoGridFsClientImpl.lambda$8(Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl$MapAndCountBuffer;Ljava/lang/Void;)Ljava/lang/Long; (6)
(Ljava/lang/Void;)Ljava/lang/Long;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)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 4 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 4 1 publisher Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
0 4 2 stream Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;
1 4 3 adapter Lio/vertx/core/streams/ReadStream<Ljava/nio/ByteBuffer;>;
2 4 4 mapper Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl$MapAndCountBuffer;
3 4 5 rs Lio/vertx/ext/mongo/impl/MappingStream<Ljava/nio/ByteBuffer;Lio/vertx/core/buffer/Buffer;>;
Signature: (Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/Future<Ljava/lang/Long;>;
MethodParameters:
Name Flags
publisher
stream
private io.vertx.core.Future lambda$2(io.vertx.ext.mongo.GridFsUploadOptions, java.lang.String, io.vertx.core.file.AsyncFile);
descriptor: (Lio/vertx/ext/mongo/GridFsUploadOptions;Ljava/lang/String;Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 3 0: new io.vertx.ext.mongo.impl.GridFSReadStreamPublisher
dup
aload 3
invokespecial io.vertx.ext.mongo.impl.GridFSReadStreamPublisher.<init>:(Lio/vertx/core/streams/ReadStream;)V
astore 4
start local 4 1: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 5
start local 5 2: aload 1
ifnonnull 5
3: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
aload 4
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.uploadFromPublisher:(Ljava/lang/String;Lorg/reactivestreams/Publisher;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSUploadPublisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 5
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSUploadPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
4: goto 10
5: StackMap locals: io.vertx.ext.mongo.impl.GridFSReadStreamPublisher io.vertx.core.Promise
StackMap stack:
new com.mongodb.client.gridfs.model.GridFSUploadOptions
dup
invokespecial com.mongodb.client.gridfs.model.GridFSUploadOptions.<init>:()V
astore 6
start local 6 6: aload 6
aload 1
invokevirtual io.vertx.ext.mongo.GridFsUploadOptions.getChunkSizeBytes:()Ljava/lang/Integer;
invokevirtual com.mongodb.client.gridfs.model.GridFSUploadOptions.chunkSizeBytes:(Ljava/lang/Integer;)Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;
pop
7: aload 1
invokevirtual io.vertx.ext.mongo.GridFsUploadOptions.getMetadata:()Lio/vertx/core/json/JsonObject;
ifnull 9
8: aload 6
new org.bson.Document
dup
aload 1
invokevirtual io.vertx.ext.mongo.GridFsUploadOptions.getMetadata:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.core.json.JsonObject.getMap:()Ljava/util/Map;
invokespecial org.bson.Document.<init>:(Ljava/util/Map;)V
invokevirtual com.mongodb.client.gridfs.model.GridFSUploadOptions.metadata:(Lorg/bson/Document;)Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;
pop
9: StackMap locals: com.mongodb.client.gridfs.model.GridFSUploadOptions
StackMap stack:
aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 2
aload 4
aload 6
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.uploadFromPublisher:(Ljava/lang/String;Lorg/reactivestreams/Publisher;Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSUploadPublisher;
new io.vertx.ext.mongo.impl.SingleResultSubscriber
dup
aload 5
invokespecial io.vertx.ext.mongo.impl.SingleResultSubscriber.<init>:(Lio/vertx/core/Promise;)V
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSUploadPublisher.subscribe:(Lorg/reactivestreams/Subscriber;)V
end local 6 10: StackMap locals:
StackMap stack:
aload 5
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;
org/bson/types/ObjectId.toHexString()Ljava/lang/String; (5)
(Lorg/bson/types/ObjectId;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 5 end local 4 end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 11 3 file Lio/vertx/core/file/AsyncFile;
1 11 4 publisher Lio/vertx/ext/mongo/impl/GridFSReadStreamPublisher;
2 11 5 promise Lio/vertx/core/Promise<Lorg/bson/types/ObjectId;>;
6 10 6 uploadOptions Lcom/mongodb/client/gridfs/model/GridFSUploadOptions;
private io.vertx.core.Future lambda$4(java.lang.String, io.vertx.core.file.AsyncFile);
descriptor: (Ljava/lang/String;Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 1
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.downloadToPublisher:(Ljava/lang/String;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
astore 3
start local 3 1: aload 0
aload 3
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.handleDownload:(Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 2 2 file Lio/vertx/core/file/AsyncFile;
1 2 3 publisher Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
private io.vertx.core.Future lambda$5(java.lang.String, io.vertx.core.file.AsyncFile);
descriptor: (Ljava/lang/String;Lio/vertx/core/file/AsyncFile;)Lio/vertx/core/Future;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=3
start local 0 start local 2 0: new org.bson.types.ObjectId
dup
aload 1
invokespecial org.bson.types.ObjectId.<init>:(Ljava/lang/String;)V
astore 3
start local 3 1: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl.bucket:Lcom/mongodb/reactivestreams/client/gridfs/GridFSBucket;
aload 3
invokeinterface com.mongodb.reactivestreams.client.gridfs.GridFSBucket.downloadToPublisher:(Lorg/bson/types/ObjectId;)Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
astore 4
start local 4 2: aload 0
aload 4
aload 2
invokevirtual io.vertx.ext.mongo.impl.MongoGridFsClientImpl.handleDownload:(Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;Lio/vertx/core/streams/WriteStream;)Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl;
0 3 2 file Lio/vertx/core/file/AsyncFile;
1 3 3 objectId Lorg/bson/types/ObjectId;
2 3 4 publisher Lcom/mongodb/reactivestreams/client/gridfs/GridFSDownloadPublisher;
private static java.lang.String lambda$6(com.mongodb.client.gridfs.model.GridFSFile);
descriptor: (Lcom/mongodb/client/gridfs/model/GridFSFile;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.mongodb.client.gridfs.model.GridFSFile.getObjectId:()Lorg/bson/types/ObjectId;
invokevirtual org.bson.types.ObjectId.toHexString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 gridFSFile Lcom/mongodb/client/gridfs/model/GridFSFile;
private static java.lang.String lambda$7(com.mongodb.client.gridfs.model.GridFSFile);
descriptor: (Lcom/mongodb/client/gridfs/model/GridFSFile;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.mongodb.client.gridfs.model.GridFSFile.getObjectId:()Lorg/bson/types/ObjectId;
invokevirtual org.bson.types.ObjectId.toHexString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 gridFSFile Lcom/mongodb/client/gridfs/model/GridFSFile;
private static java.lang.Long lambda$8(io.vertx.ext.mongo.impl.MongoGridFsClientImpl$MapAndCountBuffer, java.lang.Void);
descriptor: (Lio/vertx/ext/mongo/impl/MongoGridFsClientImpl$MapAndCountBuffer;Ljava/lang/Void;)Ljava/lang/Long;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
getfield io.vertx.ext.mongo.impl.MongoGridFsClientImpl$MapAndCountBuffer.count:J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
}
SourceFile: "MongoGridFsClientImpl.java"
NestMembers:
io.vertx.ext.mongo.impl.MongoGridFsClientImpl$MapAndCountBuffer
InnerClasses:
private MapAndCountBuffer = io.vertx.ext.mongo.impl.MongoGridFsClientImpl$MapAndCountBuffer of io.vertx.ext.mongo.impl.MongoGridFsClientImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles