com.mongodb.rx.client

Interface MongoCollection<TDocument>

Type Parameters:

TDocument - The type that this collection will encode documents from and decode documents to.

@ThreadSafe
public interface MongoCollection<TDocument>

The MongoCollection interface.

Note: Additions to this interface will not be considered to break binary compatibility.

Since:

1.0

Method Summary

Modifier and Type	Method and Description
AggregateObservable<org.bson.Document>	aggregate(List<? extends org.bson.conversions.Bson> pipeline) Aggregates documents according to the specified aggregation pipeline.
<TResult> AggregateObservable<TResult>	aggregate(List<? extends org.bson.conversions.Bson> pipeline, Class<TResult> clazz) Aggregates documents according to the specified aggregation pipeline.
rx.Observable<com.mongodb.bulk.BulkWriteResult>	bulkWrite(List<? extends com.mongodb.client.model.WriteModel<? extends TDocument>> requests) Executes a mix of inserts, updates, replaces, and deletes.
rx.Observable<com.mongodb.bulk.BulkWriteResult>	bulkWrite(List<? extends com.mongodb.client.model.WriteModel<? extends TDocument>> requests, com.mongodb.client.model.BulkWriteOptions options) Executes a mix of inserts, updates, replaces, and deletes.
rx.Observable<Long>	count() Counts the number of documents in the collection.
rx.Observable<Long>	count(org.bson.conversions.Bson filter) Counts the number of documents in the collection according to the given options.
rx.Observable<Long>	count(org.bson.conversions.Bson filter, com.mongodb.client.model.CountOptions options) Counts the number of documents in the collection according to the given options.
rx.Observable<String>	createIndex(org.bson.conversions.Bson key) Creates an index.
rx.Observable<String>	createIndex(org.bson.conversions.Bson key, com.mongodb.client.model.IndexOptions options) Creates an index.
rx.Observable<String>	createIndexes(List<com.mongodb.client.model.IndexModel> indexes) Create multiple indexes.
rx.Observable<com.mongodb.client.result.DeleteResult>	deleteMany(org.bson.conversions.Bson filter) Removes all documents from the collection that match the given query filter.
rx.Observable<com.mongodb.client.result.DeleteResult>	deleteMany(org.bson.conversions.Bson filter, com.mongodb.client.model.DeleteOptions options) Removes all documents from the collection that match the given query filter.
rx.Observable<com.mongodb.client.result.DeleteResult>	deleteOne(org.bson.conversions.Bson filter) Removes at most one document from the collection that matches the given filter.
rx.Observable<com.mongodb.client.result.DeleteResult>	deleteOne(org.bson.conversions.Bson filter, com.mongodb.client.model.DeleteOptions options) Removes at most one document from the collection that matches the given filter.
<TResult> DistinctObservable<TResult>	distinct(String fieldName, org.bson.conversions.Bson filter, Class<TResult> resultClass) Gets the distinct values of the specified field name.
<TResult> DistinctObservable<TResult>	distinct(String fieldName, Class<TResult> resultClass) Gets the distinct values of the specified field name.
rx.Observable<Success>	drop() Drops this collection from the Database.
rx.Observable<Success>	dropIndex(org.bson.conversions.Bson keys) Drops the index given the keys used to create it.
rx.Observable<Success>	dropIndex(String indexName) Drops the given index.
rx.Observable<Success>	dropIndexes() Drop all the indexes on this collection, except for the default on _id.
FindObservable<TDocument>	find() Finds all documents in the collection.
FindObservable<TDocument>	find(org.bson.conversions.Bson filter) Finds all documents in the collection.
<TResult> FindObservable<TResult>	find(org.bson.conversions.Bson filter, Class<TResult> clazz) Finds all documents in the collection.
<TResult> FindObservable<TResult>	find(Class<TResult> clazz) Finds all documents in the collection.
rx.Observable<TDocument>	findOneAndDelete(org.bson.conversions.Bson filter) Atomically find a document and remove it.
rx.Observable<TDocument>	findOneAndDelete(org.bson.conversions.Bson filter, com.mongodb.client.model.FindOneAndDeleteOptions options) Atomically find a document and remove it.
rx.Observable<TDocument>	findOneAndReplace(org.bson.conversions.Bson filter, TDocument replacement) Atomically find a document and replace it.
rx.Observable<TDocument>	findOneAndReplace(org.bson.conversions.Bson filter, TDocument replacement, com.mongodb.client.model.FindOneAndReplaceOptions options) Atomically find a document and replace it.
rx.Observable<TDocument>	findOneAndUpdate(org.bson.conversions.Bson filter, org.bson.conversions.Bson update) Atomically find a document and update it.
rx.Observable<TDocument>	findOneAndUpdate(org.bson.conversions.Bson filter, org.bson.conversions.Bson update, com.mongodb.client.model.FindOneAndUpdateOptions options) Atomically find a document and update it.
org.bson.codecs.configuration.CodecRegistry	getCodecRegistry() Get the codec registry for the MongoCollection.
Class<TDocument>	getDocumentClass() Get the class of documents stored in this collection.
com.mongodb.MongoNamespace	getNamespace() Gets the namespace of this collection.
ObservableAdapter	getObservableAdapter() Get the ObservableAdapter for this collection.
com.mongodb.ReadConcern	getReadConcern() Get the read concern for the MongoCollection.
com.mongodb.ReadPreference	getReadPreference() Get the read preference for the MongoCollection.
com.mongodb.WriteConcern	getWriteConcern() Get the write concern for the MongoCollection.
rx.Observable<Success>	insertMany(List<? extends TDocument> documents) Inserts a batch of documents.
rx.Observable<Success>	insertMany(List<? extends TDocument> documents, com.mongodb.client.model.InsertManyOptions options) Inserts a batch of documents.
rx.Observable<Success>	insertOne(TDocument document) Inserts the provided document.
rx.Observable<Success>	insertOne(TDocument document, com.mongodb.client.model.InsertOneOptions options) Inserts the provided document.
ListIndexesObservable<org.bson.Document>	listIndexes() Get all the indexes in this collection.
<TResult> ListIndexesObservable<TResult>	listIndexes(Class<TResult> clazz) Get all the indexes in this collection.
MapReduceObservable<org.bson.Document>	mapReduce(String mapFunction, String reduceFunction) Aggregates documents according to the specified map-reduce function.
<TResult> MapReduceObservable<TResult>	mapReduce(String mapFunction, String reduceFunction, Class<TResult> clazz) Aggregates documents according to the specified map-reduce function.
rx.Observable<Success>	renameCollection(com.mongodb.MongoNamespace newCollectionNamespace) Rename the collection with oldCollectionName to the newCollectionName.
rx.Observable<Success>	renameCollection(com.mongodb.MongoNamespace newCollectionNamespace, com.mongodb.client.model.RenameCollectionOptions options) Rename the collection with oldCollectionName to the newCollectionName.
rx.Observable<com.mongodb.client.result.UpdateResult>	replaceOne(org.bson.conversions.Bson filter, TDocument replacement) Replace a document in the collection according to the specified arguments.
rx.Observable<com.mongodb.client.result.UpdateResult>	replaceOne(org.bson.conversions.Bson filter, TDocument replacement, com.mongodb.client.model.UpdateOptions options) Replace a document in the collection according to the specified arguments.
rx.Observable<com.mongodb.client.result.UpdateResult>	updateMany(org.bson.conversions.Bson filter, org.bson.conversions.Bson update) Update all documents in the collection according to the specified arguments.
rx.Observable<com.mongodb.client.result.UpdateResult>	updateMany(org.bson.conversions.Bson filter, org.bson.conversions.Bson update, com.mongodb.client.model.UpdateOptions options) Update all documents in the collection according to the specified arguments.
rx.Observable<com.mongodb.client.result.UpdateResult>	updateOne(org.bson.conversions.Bson filter, org.bson.conversions.Bson update) Update a single document in the collection according to the specified arguments.
rx.Observable<com.mongodb.client.result.UpdateResult>	updateOne(org.bson.conversions.Bson filter, org.bson.conversions.Bson update, com.mongodb.client.model.UpdateOptions options) Update a single document in the collection according to the specified arguments.
MongoCollection<TDocument>	withCodecRegistry(org.bson.codecs.configuration.CodecRegistry codecRegistry) Create a new MongoCollection instance with a different codec registry.
<NewTDocument> MongoCollection<NewTDocument>	withDocumentClass(Class<NewTDocument> clazz) Create a new MongoCollection instance with a different default class to cast any documents returned from the database into..
MongoCollection<TDocument>	withObservableAdapter(ObservableAdapter observableAdapter) Create a new MongoCollection instance with a different ObservableAdapter.
MongoCollection<TDocument>	withReadConcern(com.mongodb.ReadConcern readConcern) Create a new MongoCollection instance with a different read concern.
MongoCollection<TDocument>	withReadPreference(com.mongodb.ReadPreference readPreference) Create a new MongoCollection instance with a different read preference.
MongoCollection<TDocument>	withWriteConcern(com.mongodb.WriteConcern writeConcern) Create a new MongoCollection instance with a different write concern.

Method Detail

getNamespace

com.mongodb.MongoNamespace getNamespace()

Gets the namespace of this collection.

Returns:

the namespace

getDocumentClass

Class<TDocument> getDocumentClass()

Get the class of documents stored in this collection.

Returns:

the class

getObservableAdapter

ObservableAdapter getObservableAdapter()

Get the ObservableAdapter for this collection.

Returns:

the ObservableAdapter

Since:

1.2

getCodecRegistry

org.bson.codecs.configuration.CodecRegistry getCodecRegistry()

Get the codec registry for the MongoCollection.

Returns:

the CodecRegistry

getReadPreference

com.mongodb.ReadPreference getReadPreference()

Get the read preference for the MongoCollection.

Returns:

the ReadPreference

getWriteConcern

com.mongodb.WriteConcern getWriteConcern()

Get the write concern for the MongoCollection.

Returns:

the WriteConcern

getReadConcern

com.mongodb.ReadConcern getReadConcern()

Get the read concern for the MongoCollection.

Returns:

the ReadConcern

Since:

1.2

Since server release

3.2

withDocumentClass

<NewTDocument> MongoCollection<NewTDocument> withDocumentClass(Class<NewTDocument> clazz)

Create a new MongoCollection instance with a different default class to cast any documents returned from the database into..

Type Parameters:

NewTDocument - The type that the new collection will encode documents from and decode documents to

Parameters:

clazz - the default class to cast any documents returned from the database into.

Returns:

a new MongoCollection instance with the different default class

withCodecRegistry

MongoCollection<TDocument> withCodecRegistry(org.bson.codecs.configuration.CodecRegistry codecRegistry)

Create a new MongoCollection instance with a different codec registry.

Parameters:

codecRegistry - the new CodecRegistry for the collection

Returns:

a new MongoCollection instance with the different codec registry

withReadPreference

MongoCollection<TDocument> withReadPreference(com.mongodb.ReadPreference readPreference)

Create a new MongoCollection instance with a different read preference.

Parameters:

readPreference - the new ReadPreference for the collection

Returns:

a new MongoCollection instance with the different readPreference

withWriteConcern

MongoCollection<TDocument> withWriteConcern(com.mongodb.WriteConcern writeConcern)

Create a new MongoCollection instance with a different write concern.

Parameters:

writeConcern - the new WriteConcern for the collection

Returns:

a new MongoCollection instance with the different writeConcern

withReadConcern

MongoCollection<TDocument> withReadConcern(com.mongodb.ReadConcern readConcern)

Create a new MongoCollection instance with a different read concern.

Parameters:

readConcern - the new ReadConcern for the collection

Returns:

a new MongoCollection instance with the different ReadConcern

Since:

1.2

Since server release

3.2

withObservableAdapter

MongoCollection<TDocument> withObservableAdapter(ObservableAdapter observableAdapter)

Create a new MongoCollection instance with a different ObservableAdapter.

Parameters:

observableAdapter - the new ObservableAdapter for the collection

Returns:

a new MongoCollection instance with the different ObservableAdapter

Since:

1.2

count

rx.Observable<Long> count()

Counts the number of documents in the collection.

Returns:

an Observable with a single element indicating the number of documents

count

rx.Observable<Long> count(org.bson.conversions.Bson filter)

Counts the number of documents in the collection according to the given options.

Parameters:

filter - the query filter

Returns:

an Observable with a single element indicating the number of documents

count

rx.Observable<Long> count(org.bson.conversions.Bson filter,
                          com.mongodb.client.model.CountOptions options)

Counts the number of documents in the collection according to the given options.

Parameters:

filter - the query filter

options - the options describing the count

Returns:

an Observable with a single element indicating the number of documents

distinct

<TResult> DistinctObservable<TResult> distinct(String fieldName,
                                               Class<TResult> resultClass)

Gets the distinct values of the specified field name.

Type Parameters:

TResult - the target type of the iterable.

Parameters:

fieldName - the field name

resultClass - the default class to cast any distinct items into.

Returns:

an Observable emitting the sequence of distinct values

MongoDB documentation

Distinct

distinct

<TResult> DistinctObservable<TResult> distinct(String fieldName,
                                               org.bson.conversions.Bson filter,
                                               Class<TResult> resultClass)

Gets the distinct values of the specified field name.

Type Parameters:

TResult - the target type of the iterable.

Parameters:

fieldName - the field name

filter - the query filter

resultClass - the default class to cast any distinct items into.

Returns:

an iterable of distinct values

MongoDB documentation

Distinct

find

FindObservable<TDocument> find()

Finds all documents in the collection.

Returns:

the fluent find interface

MongoDB documentation

Find

find

<TResult> FindObservable<TResult> find(Class<TResult> clazz)

Finds all documents in the collection.

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

clazz - the class to decode each document into

Returns:

the fluent find interface

MongoDB documentation

Find

find

FindObservable<TDocument> find(org.bson.conversions.Bson filter)

Finds all documents in the collection.

Parameters:

filter - the query filter

Returns:

the fluent find interface

MongoDB documentation

Find

find

<TResult> FindObservable<TResult> find(org.bson.conversions.Bson filter,
                                       Class<TResult> clazz)

Finds all documents in the collection.

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

filter - the query filter

clazz - the class to decode each document into

Returns:

the fluent find interface

MongoDB documentation

Find

aggregate

AggregateObservable<org.bson.Document> aggregate(List<? extends org.bson.conversions.Bson> pipeline)

Aggregates documents according to the specified aggregation pipeline.

Parameters:

pipeline - the aggregate pipeline

Returns:

an Observable containing the result of the aggregation operation

MongoDB documentation

Aggregation

aggregate

<TResult> AggregateObservable<TResult> aggregate(List<? extends org.bson.conversions.Bson> pipeline,
                                                 Class<TResult> clazz)

Aggregates documents according to the specified aggregation pipeline.

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

pipeline - the aggregate pipeline

clazz - the class to decode each document into

Returns:

an Observable containing the result of the aggregation operation

MongoDB documentation

Aggregation

mapReduce

MapReduceObservable<org.bson.Document> mapReduce(String mapFunction,
                                                 String reduceFunction)

Aggregates documents according to the specified map-reduce function.

Parameters:

mapFunction - A JavaScript function that associates or "maps" a value with a key and emits the key and value pair.

reduceFunction - A JavaScript function that "reduces" to a single object all the values associated with a particular key.

Returns:

an Observable containing the result of the map-reduce operation

MongoDB documentation

map-reduce

mapReduce

<TResult> MapReduceObservable<TResult> mapReduce(String mapFunction,
                                                 String reduceFunction,
                                                 Class<TResult> clazz)

Aggregates documents according to the specified map-reduce function.

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

mapFunction - A JavaScript function that associates or "maps" a value with a key and emits the key and value pair.

reduceFunction - A JavaScript function that "reduces" to a single object all the values associated with a particular key.

clazz - the class to decode each resulting document into.

Returns:

an Observable containing the result of the map-reduce operation

MongoDB documentation

map-reduce

bulkWrite

rx.Observable<com.mongodb.bulk.BulkWriteResult> bulkWrite(List<? extends com.mongodb.client.model.WriteModel<? extends TDocument>> requests)

Executes a mix of inserts, updates, replaces, and deletes.

Parameters:

requests - the writes to execute

Returns:

an Observable with a single element the BulkWriteResult

bulkWrite

rx.Observable<com.mongodb.bulk.BulkWriteResult> bulkWrite(List<? extends com.mongodb.client.model.WriteModel<? extends TDocument>> requests,
                                                          com.mongodb.client.model.BulkWriteOptions options)

Executes a mix of inserts, updates, replaces, and deletes.

Parameters:

requests - the writes to execute

options - the options to apply to the bulk write operation

Returns:

an Observable with a single element the BulkWriteResult

insertOne

rx.Observable<Success> insertOne(TDocument document)

Inserts the provided document. If the document is missing an identifier, the driver should generate one.

Parameters:

document - the document to insert

Returns:

an Observable with a single element indicating when the operation has completed or with either a com.mongodb.DuplicateKeyException or com.mongodb.MongoException

insertOne

rx.Observable<Success> insertOne(TDocument document,
                                 com.mongodb.client.model.InsertOneOptions options)

Inserts the provided document. If the document is missing an identifier, the driver should generate one.

Parameters:

document - the document to insert

options - the options to apply to the operation

Returns:

an Observable with a single element indicating when the operation has completed or with either a com.mongodb.DuplicateKeyException or com.mongodb.MongoException

Since:

1.2

insertMany

rx.Observable<Success> insertMany(List<? extends TDocument> documents)

Inserts a batch of documents. The preferred way to perform bulk inserts is to use the BulkWrite API. However, when talking with a server < 2.6, using this method will be faster due to constraints in the bulk API related to error handling.

Parameters:

documents - the documents to insert

Returns:

an Observable with a single element indicating when the operation has completed or with either a com.mongodb.DuplicateKeyException or com.mongodb.MongoException

insertMany

rx.Observable<Success> insertMany(List<? extends TDocument> documents,
                                  com.mongodb.client.model.InsertManyOptions options)

Inserts a batch of documents. The preferred way to perform bulk inserts is to use the BulkWrite API. However, when talking with a server < 2.6, using this method will be faster due to constraints in the bulk API related to error handling.

Parameters:

documents - the documents to insert

options - the options to apply to the operation

Returns:

an Observable with a single element indicating when the operation has completed or with either a com.mongodb.DuplicateKeyException or com.mongodb.MongoException

deleteOne

rx.Observable<com.mongodb.client.result.DeleteResult> deleteOne(org.bson.conversions.Bson filter)

Removes at most one document from the collection that matches the given filter. If no documents match, the collection is not modified.

Parameters:

filter - the query filter to apply the the delete operation

Returns:

an Observable with a single element the DeleteResult or with an com.mongodb.MongoException

deleteOne

rx.Observable<com.mongodb.client.result.DeleteResult> deleteOne(org.bson.conversions.Bson filter,
                                                                com.mongodb.client.model.DeleteOptions options)

Removes at most one document from the collection that matches the given filter. If no documents match, the collection is not modified.

Parameters:

filter - the query filter to apply the the delete operation

options - the options to apply to the delete operation

Returns:

an Observable with a single element the DeleteResult or with an com.mongodb.MongoException

Since:

1.3

deleteMany

rx.Observable<com.mongodb.client.result.DeleteResult> deleteMany(org.bson.conversions.Bson filter)

Removes all documents from the collection that match the given query filter. If no documents match, the collection is not modified.

Parameters:

filter - the query filter to apply the the delete operation

Returns:

an Observable with a single element the DeleteResult or with an com.mongodb.MongoException

deleteMany

rx.Observable<com.mongodb.client.result.DeleteResult> deleteMany(org.bson.conversions.Bson filter,
                                                                 com.mongodb.client.model.DeleteOptions options)

Removes all documents from the collection that match the given query filter. If no documents match, the collection is not modified.

Parameters:

filter - the query filter to apply the the delete operation

options - the options to apply to the delete operation

Returns:

an Observable with a single element the DeleteResult or with an com.mongodb.MongoException

Since:

1.3

replaceOne

rx.Observable<com.mongodb.client.result.UpdateResult> replaceOne(org.bson.conversions.Bson filter,
                                                                 TDocument replacement)

Replace a document in the collection according to the specified arguments.

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

Returns:

an Observable with a single element the UpdateResult

MongoDB documentation

Replace

replaceOne

rx.Observable<com.mongodb.client.result.UpdateResult> replaceOne(org.bson.conversions.Bson filter,
                                                                 TDocument replacement,
                                                                 com.mongodb.client.model.UpdateOptions options)

Replace a document in the collection according to the specified arguments.

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

options - the options to apply to the replace operation

Returns:

an Observable with a single element the UpdateResult

MongoDB documentation

Replace

updateOne

rx.Observable<com.mongodb.client.result.UpdateResult> updateOne(org.bson.conversions.Bson filter,
                                                                org.bson.conversions.Bson update)

Update a single document in the collection according to the specified arguments.

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

Returns:

an Observable with a single element the UpdateResult

MongoDB documentation

Updates

Update Operators

updateOne

rx.Observable<com.mongodb.client.result.UpdateResult> updateOne(org.bson.conversions.Bson filter,
                                                                org.bson.conversions.Bson update,
                                                                com.mongodb.client.model.UpdateOptions options)

Update a single document in the collection according to the specified arguments.

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

options - the options to apply to the update operation

Returns:

an Observable with a single element the UpdateResult

MongoDB documentation

Updates

Update Operators

updateMany

rx.Observable<com.mongodb.client.result.UpdateResult> updateMany(org.bson.conversions.Bson filter,
                                                                 org.bson.conversions.Bson update)

Update all documents in the collection according to the specified arguments.

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

Returns:

an Observable with a single element the UpdateResult

MongoDB documentation

Updates

Update Operators

updateMany

rx.Observable<com.mongodb.client.result.UpdateResult> updateMany(org.bson.conversions.Bson filter,
                                                                 org.bson.conversions.Bson update,
                                                                 com.mongodb.client.model.UpdateOptions options)

Update all documents in the collection according to the specified arguments.

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

options - the options to apply to the update operation

Returns:

an Observable with a single element the UpdateResult

MongoDB documentation

Updates

Update Operators

findOneAndDelete

rx.Observable<TDocument> findOneAndDelete(org.bson.conversions.Bson filter)

Atomically find a document and remove it.

Parameters:

filter - the query filter to find the document with

Returns:

an Observable with a single element the document that was removed. If no documents matched the query filter, then the observer will complete without emitting any items

findOneAndDelete

rx.Observable<TDocument> findOneAndDelete(org.bson.conversions.Bson filter,
                                          com.mongodb.client.model.FindOneAndDeleteOptions options)

Atomically find a document and remove it.

Parameters:

filter - the query filter to find the document with

options - the options to apply to the operation

Returns:

an Observable with a single element the document that was removed. If no documents matched the query filter, then the observer will complete without emitting any items

findOneAndReplace

rx.Observable<TDocument> findOneAndReplace(org.bson.conversions.Bson filter,
                                           TDocument replacement)

Atomically find a document and replace it.

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

Returns:

an Observable with a single element the document that was replaced. Depending on the value of the returnOriginal property, this will either be the document as it was before the update or as it is after the update. If no documents matched the query filter, then the observer will complete without emitting any items

findOneAndReplace

rx.Observable<TDocument> findOneAndReplace(org.bson.conversions.Bson filter,
                                           TDocument replacement,
                                           com.mongodb.client.model.FindOneAndReplaceOptions options)

Atomically find a document and replace it.

Parameters:

filter - the query filter to apply the the replace operation

replacement - the replacement document

options - the options to apply to the operation

Returns:

an Observable with a single element the document that was replaced. Depending on the value of the returnOriginal property, this will either be the document as it was before the update or as it is after the update. If no documents matched the query filter, then the observer will complete without emitting any items

findOneAndUpdate

rx.Observable<TDocument> findOneAndUpdate(org.bson.conversions.Bson filter,
                                          org.bson.conversions.Bson update)

Atomically find a document and update it.

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

Returns:

an Observable with a single element the document that was updated before the update was applied. If no documents matched the query filter, then the observer will complete without emitting any items

findOneAndUpdate

rx.Observable<TDocument> findOneAndUpdate(org.bson.conversions.Bson filter,
                                          org.bson.conversions.Bson update,
                                          com.mongodb.client.model.FindOneAndUpdateOptions options)

Atomically find a document and update it.

Parameters:

filter - a document describing the query filter, which may not be null.

update - a document describing the update, which may not be null. The update to apply must include only update operators.

options - the options to apply to the operation

Returns:

an Observable with a single element the document that was updated. Depending on the value of the returnOriginal property, this will either be the document as it was before the update or as it is after the update. If no documents matched the query filter, then the observer will complete without emitting any items

drop

rx.Observable<Success> drop()

Drops this collection from the Database.

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Drop Collection

createIndex

rx.Observable<String> createIndex(org.bson.conversions.Bson key)

Creates an index.

Parameters:

key - an object describing the index key(s), which may not be null.

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Ensure Index

createIndex

rx.Observable<String> createIndex(org.bson.conversions.Bson key,
                                  com.mongodb.client.model.IndexOptions options)

Creates an index.

Parameters:

key - an object describing the index key(s), which may not be null.

options - the options for the index

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Ensure Index

createIndexes

rx.Observable<String> createIndexes(List<com.mongodb.client.model.IndexModel> indexes)

Create multiple indexes.

Parameters:

indexes - the list of indexes

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Create indexes

Since server release

2.6

listIndexes

ListIndexesObservable<org.bson.Document> listIndexes()

Get all the indexes in this collection.

Returns:

the fluent list indexes interface

MongoDB documentation

listIndexes

listIndexes

<TResult> ListIndexesObservable<TResult> listIndexes(Class<TResult> clazz)

Get all the indexes in this collection.

Type Parameters:

TResult - the target document type of the iterable.

Parameters:

clazz - the class to decode each document into

Returns:

the fluent list indexes interface

MongoDB documentation

listIndexes

dropIndex

rx.Observable<Success> dropIndex(String indexName)

Drops the given index.

Parameters:

indexName - the name of the index to remove

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Drop Indexes

dropIndex

rx.Observable<Success> dropIndex(org.bson.conversions.Bson keys)

Drops the index given the keys used to create it.

Parameters:

keys - the keys of the index to remove

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Drop indexes

dropIndexes

rx.Observable<Success> dropIndexes()

Drop all the indexes on this collection, except for the default on _id.

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Drop Indexes

renameCollection

rx.Observable<Success> renameCollection(com.mongodb.MongoNamespace newCollectionNamespace)

Rename the collection with oldCollectionName to the newCollectionName.

Parameters:

newCollectionNamespace - the namespace the collection will be renamed to

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Rename collection

renameCollection

rx.Observable<Success> renameCollection(com.mongodb.MongoNamespace newCollectionNamespace,
                                        com.mongodb.client.model.RenameCollectionOptions options)

Rename the collection with oldCollectionName to the newCollectionName.

Parameters:

newCollectionNamespace - the name the collection will be renamed to

options - the options for renaming a collection

Returns:

an Observable with a single element indicating when the operation has completed

MongoDB documentation

Rename collection