io.vertx.rxjava3.ext.mongo

Class MongoGridFsClient

java.lang.Object

io.vertx.rxjava3.ext.mongo.MongoGridFsClient

public class MongoGridFsClient
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<MongoGridFsClient>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
MongoGridFsClient(MongoGridFsClient delegate)
MongoGridFsClient(Object delegate)

Method Summary

Modifier and Type	Method and Description
void	close() Close the client and release its resources
Completable	delete(String id) Deletes a file by it's ID
Single<Long>	downloadByFileName(WriteStream<Buffer> stream, String fileName)
Single<Long>	downloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)
Single<Long>	downloadById(WriteStream<Buffer> stream, String id)
Single<Long>	downloadFile(String fileName) Downloads a file.
Single<Long>	downloadFileAs(String fileName, String newFileName) Downloads a file and gives it a new name.
Single<Long>	downloadFileByID(String id, String fileName) Downloads a file using the ID generated by GridFs.
Completable	drop() Drops the entire file bucket with all of its contents
boolean	equals(Object o)
Single<List<String>>	findAllIds() Finds all file ids in the bucket
Single<List<String>>	findIds(JsonObject query) Finds all file ids that match a query.
MongoGridFsClient	getDelegate()
int	hashCode()
static MongoGridFsClient	newInstance(MongoGridFsClient arg)
ReadStream<Buffer>	readByFileName(String fileName) Read file by name to ReadStream
ReadStream<Buffer>	readByFileNameWithOptions(String fileName, GridFsDownloadOptions options) Read file by name to ReadStream with options
ReadStream<Buffer>	readById(String id) Read file by id to ReadStream
Completable	rxDelete(String id) Deletes a file by it's ID
Single<Long>	rxDownloadByFileName(WriteStream<Buffer> stream, String fileName)
Single<Long>	rxDownloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options)
Single<Long>	rxDownloadById(WriteStream<Buffer> stream, String id)
Single<Long>	rxDownloadFile(String fileName) Downloads a file.
Single<Long>	rxDownloadFileAs(String fileName, String newFileName) Downloads a file and gives it a new name.
Single<Long>	rxDownloadFileByID(String id, String fileName) Downloads a file using the ID generated by GridFs.
Completable	rxDrop() Drops the entire file bucket with all of its contents
Single<List<String>>	rxFindAllIds() Finds all file ids in the bucket
Single<List<String>>	rxFindIds(JsonObject query) Finds all file ids that match a query.
Single<String>	rxUploadByFileName(Flowable<Buffer> stream, String fileName)
Single<String>	rxUploadByFileNameWithOptions(Flowable<Buffer> stream, String fileName, GridFsUploadOptions options)
Single<String>	rxUploadFile(String fileName) Upload a file to gridfs
Single<String>	rxUploadFileWithOptions(String fileName, GridFsUploadOptions options) Upload a file to gridfs with options
String	toString()
Single<String>	uploadByFileName(Flowable<Buffer> stream, String fileName)
Single<String>	uploadByFileNameWithOptions(Flowable<Buffer> stream, String fileName, GridFsUploadOptions options)
Single<String>	uploadFile(String fileName) Upload a file to gridfs
Single<String>	uploadFileWithOptions(String fileName, GridFsUploadOptions options) Upload a file to gridfs with options

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final io.vertx.lang.rx.TypeArg<MongoGridFsClient> __TYPE_ARG

Constructor Detail

MongoGridFsClient

public MongoGridFsClient(MongoGridFsClient delegate)

MongoGridFsClient

public MongoGridFsClient(Object delegate)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getDelegate

public MongoGridFsClient getDelegate()

delete

public Completable delete(String id)

Deletes a file by it's ID

Parameters:

id - the identifier of the file

Returns:

rxDelete

public Completable rxDelete(String id)

Deletes a file by it's ID

Parameters:

id - the identifier of the file

Returns:

readByFileName

public ReadStream<Buffer> readByFileName(String fileName)

Read file by name to ReadStream

Parameters:

fileName -

Returns:

readByFileNameWithOptions

public ReadStream<Buffer> readByFileNameWithOptions(String fileName,
                                                    GridFsDownloadOptions options)

Read file by name to ReadStream with options

Parameters:

fileName -

options -

Returns:

readById

public ReadStream<Buffer> readById(String id)

Read file by id to ReadStream

Parameters:

id -

Returns:

downloadByFileName

public Single<Long> downloadByFileName(WriteStream<Buffer> stream,
                                       String fileName)

rxDownloadByFileName

public Single<Long> rxDownloadByFileName(WriteStream<Buffer> stream,
                                         String fileName)

downloadByFileNameWithOptions

public Single<Long> downloadByFileNameWithOptions(WriteStream<Buffer> stream,
                                                  String fileName,
                                                  GridFsDownloadOptions options)

rxDownloadByFileNameWithOptions

public Single<Long> rxDownloadByFileNameWithOptions(WriteStream<Buffer> stream,
                                                    String fileName,
                                                    GridFsDownloadOptions options)

downloadById

public Single<Long> downloadById(WriteStream<Buffer> stream,
                                 String id)

rxDownloadById

public Single<Long> rxDownloadById(WriteStream<Buffer> stream,
                                   String id)

downloadFile

public Single<Long> downloadFile(String fileName)

Downloads a file.

Parameters:

fileName - the name of the file to download

Returns:

rxDownloadFile

public Single<Long> rxDownloadFile(String fileName)

Downloads a file.

Parameters:

fileName - the name of the file to download

Returns:

downloadFileAs

public Single<Long> downloadFileAs(String fileName,
                                   String newFileName)

Downloads a file and gives it a new name.

Parameters:

fileName - the name of the file to download

newFileName - the name the file should be saved as

Returns:

rxDownloadFileAs

public Single<Long> rxDownloadFileAs(String fileName,
                                     String newFileName)

Downloads a file and gives it a new name.

Parameters:

fileName - the name of the file to download

newFileName - the name the file should be saved as

Returns:

downloadFileByID

public Single<Long> downloadFileByID(String id,
                                     String fileName)

Downloads a file using the ID generated by GridFs.

Parameters:

id - the GridFs Object ID of the file to download

fileName -

Returns:

rxDownloadFileByID

public Single<Long> rxDownloadFileByID(String id,
                                       String fileName)

Downloads a file using the ID generated by GridFs.

Parameters:

id - the GridFs Object ID of the file to download

fileName -

Returns:

drop

public Completable drop()

Drops the entire file bucket with all of its contents

Returns:

rxDrop

public Completable rxDrop()

Drops the entire file bucket with all of its contents

Returns:

findAllIds

public Single<List<String>> findAllIds()

Finds all file ids in the bucket

Returns:

rxFindAllIds

public Single<List<String>> rxFindAllIds()

Finds all file ids in the bucket

Returns:

findIds

public Single<List<String>> findIds(JsonObject query)

Finds all file ids that match a query.

Parameters:

query - a bson query expressed as json that will be used to match files

Returns:

rxFindIds

public Single<List<String>> rxFindIds(JsonObject query)

Finds all file ids that match a query.

Parameters:

query - a bson query expressed as json that will be used to match files

Returns:

uploadByFileName

public Single<String> uploadByFileName(Flowable<Buffer> stream,
                                       String fileName)

rxUploadByFileName

public Single<String> rxUploadByFileName(Flowable<Buffer> stream,
                                         String fileName)

uploadByFileNameWithOptions

public Single<String> uploadByFileNameWithOptions(Flowable<Buffer> stream,
                                                  String fileName,
                                                  GridFsUploadOptions options)

rxUploadByFileNameWithOptions

public Single<String> rxUploadByFileNameWithOptions(Flowable<Buffer> stream,
                                                    String fileName,
                                                    GridFsUploadOptions options)

uploadFile

public Single<String> uploadFile(String fileName)

Upload a file to gridfs

Parameters:

fileName - the name of the file to store in gridfs

Returns:

rxUploadFile

public Single<String> rxUploadFile(String fileName)

Upload a file to gridfs

Parameters:

fileName - the name of the file to store in gridfs

Returns:

uploadFileWithOptions

public Single<String> uploadFileWithOptions(String fileName,
                                            GridFsUploadOptions options)

Upload a file to gridfs with options

Parameters:

fileName - the name of the file to store in gridfs

options - GridFsUploadOptions for specifying metadata and chunk size

Returns:

rxUploadFileWithOptions

public Single<String> rxUploadFileWithOptions(String fileName,
                                              GridFsUploadOptions options)

Upload a file to gridfs with options

Parameters:

fileName - the name of the file to store in gridfs

options - GridFsUploadOptions for specifying metadata and chunk size

Returns:

close

public void close()

Close the client and release its resources

newInstance

public static MongoGridFsClient newInstance(MongoGridFsClient arg)