Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def aggregate[C](clientSession: ClientSession, pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): AggregateObservable[C]

   Aggregates documents according to the specified aggregation pipeline.

   Aggregates documents according to the specified aggregation pipeline.

   clientSession

   the client session with which to associate this operation

   pipeline

   the aggregate pipeline

   returns

   a Observable containing the result of the aggregation operation Aggregation

   Since

   2.2

   Note

   Requires MongoDB 3.6 or greater

5.  def aggregate[C](pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): AggregateObservable[C]

   Aggregates documents according to the specified aggregation pipeline.

   Aggregates documents according to the specified aggregation pipeline.

   pipeline

   the aggregate pipeline

   returns

   a Observable containing the result of the aggregation operation Aggregation

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def bulkWrite(clientSession: ClientSession, requests: Seq[_ <: WriteModel[_ <: TResult]], options: BulkWriteOptions): SingleObservable[BulkWriteResult]

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

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

   clientSession

   the client session with which to associate this operation

   requests

   the writes to execute

   options

   the options to apply to the bulk write operation

   returns

   a Observable with a single element the BulkWriteResult

   Since

   2.2

   Note

   Requires MongoDB 3.6 or greater

8.  def bulkWrite(clientSession: ClientSession, requests: Seq[_ <: WriteModel[_ <: TResult]]): SingleObservable[BulkWriteResult]

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

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

   clientSession

   the client session with which to associate this operation

   requests

   the writes to execute

   returns

   a Observable with a single element the BulkWriteResult

   Since

   2.2

   Note

   Requires MongoDB 3.6 or greater

9.  def bulkWrite(requests: Seq[_ <: WriteModel[_ <: TResult]], options: BulkWriteOptions): SingleObservable[BulkWriteResult]

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

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

   requests

   the writes to execute

   options

   the options to apply to the bulk write operation

   returns

   a Observable with a single element the BulkWriteResult

10.  def bulkWrite(requests: Seq[_ <: WriteModel[_ <: TResult]]): SingleObservable[BulkWriteResult]

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

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

    requests

    the writes to execute

    returns

    a Observable with a single element the BulkWriteResult

11.  def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )

12.  lazy val codecRegistry: CodecRegistry

    Get the codec registry for the MongoDatabase.

    Get the codec registry for the MongoDatabase.

    returns

    the { @link org.bson.codecs.configuration.CodecRegistry}

13.  def count(clientSession: ClientSession, filter: Bson, options: CountOptions): SingleObservable[Long]

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

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

    clientSession

    the client session with which to associate this operation

    filter

    the query filter

    options

    the options describing the count

    returns

    a Observable with a single element indicating the number of documents

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

14.  def count(clientSession: ClientSession, filter: Bson): SingleObservable[Long]

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

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

    clientSession

    the client session with which to associate this operation

    filter

    the query filter

    returns

    a Observable with a single element indicating the number of documents

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

15.  def count(clientSession: ClientSession): SingleObservable[Long]

    Counts the number of documents in the collection.

    Counts the number of documents in the collection.

    clientSession

    the client session with which to associate this operation

    returns

    a Observable with a single element indicating the number of documents

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

16.  def count(filter: Bson, options: CountOptions): SingleObservable[Long]

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

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

    filter

    the query filter

    options

    the options describing the count

    returns

    a Observable with a single element indicating the number of documents

17.  def count(filter: Bson): SingleObservable[Long]

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

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

    filter

    the query filter

    returns

    a Observable with a single element indicating the number of documents

18.  def count(): SingleObservable[Long]

    Counts the number of documents in the collection.

    Counts the number of documents in the collection.

    returns

    a Observable with a single element indicating the number of documents

19.  def createIndex(clientSession: ClientSession, key: Bson, options: IndexOptions): SingleObservable[String]

    Create Index

    Create Index

    clientSession

    the client session with which to associate this operation

    key

    an object describing the index key(s), which may not be null. This can be of any type for which a Codec is registered

    options

    the options for the index

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

20.  def createIndex(clientSession: ClientSession, key: Bson): SingleObservable[String]

    Create Index

    Create Index

    clientSession

    the client session with which to associate this operation

    key

    an object describing the index key(s), which may not be null. This can be of any type for which a Codec is registered

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

21.  def createIndex(key: Bson, options: IndexOptions): SingleObservable[String]

    Create Index

    Create Index

    key

    an object describing the index key(s), which may not be null. This can be of any type for which a Codec is registered

    options

    the options for the index

    returns

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

22.  def createIndex(key: Bson): SingleObservable[String]

    Create Index

    Create Index

    key

    an object describing the index key(s), which may not be null. This can be of any type for which a Codec is registered

    returns

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

23.  def createIndexes(clientSession: ClientSession, models: Seq[IndexModel], createIndexOptions: CreateIndexOptions): SingleObservable[String]

    Create multiple indexes.

    Create multiple indexes.

    Create Index

    clientSession

    the client session with which to associate this operation

    models

    the list of indexes to create

    createIndexOptions

    options to use when creating indexes

    returns

    a Observable with the names of the indexes

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

24.  def createIndexes(clientSession: ClientSession, models: Seq[IndexModel]): SingleObservable[String]

    Create multiple indexes.

    Create multiple indexes.

    Create Index

    clientSession

    the client session with which to associate this operation

    models

    the list of indexes to create

    returns

    a Observable with the names of the indexes

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

25.  def createIndexes(models: Seq[IndexModel], createIndexOptions: CreateIndexOptions): SingleObservable[String]

    Create multiple indexes.

    Create multiple indexes.

    Create Index

    models

    the list of indexes to create

    createIndexOptions

    options to use when creating indexes

    returns

    a Observable with the names of the indexes

    Since

    2.2

26.  def createIndexes(models: Seq[IndexModel]): SingleObservable[String]

    Create multiple indexes.

    Create multiple indexes.

    Create Index

    models

    the list of indexes to create

    returns

    a Observable with the names of the indexes

27.  def deleteMany(clientSession: ClientSession, filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]

    Removes all documents from the collection that match the given query filter.

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

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the delete operation

    options

    the options to apply to the delete operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

28.  def deleteMany(clientSession: ClientSession, filter: Bson): SingleObservable[DeleteResult]

    Removes all documents from the collection that match the given query filter.

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

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the delete operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

29.  def deleteMany(filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]

    Removes all documents from the collection that match the given query filter.

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

    filter

    the query filter to apply the the delete operation

    options

    the options to apply to the delete operation

    returns

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

    Since

    1.2

30.  def deleteMany(filter: Bson): SingleObservable[DeleteResult]

    Removes all documents from the collection that match the given query filter.

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

    filter

    the query filter to apply the the delete operation

    returns

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

31.  def deleteOne(clientSession: ClientSession, filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]

    Removes at most one document from the collection that matches the given filter.

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

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the delete operation

    options

    the options to apply to the delete operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

32.  def deleteOne(clientSession: ClientSession, filter: Bson): SingleObservable[DeleteResult]

    Removes at most one document from the collection that matches the given filter.

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

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the delete operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

33.  def deleteOne(filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]

    Removes at most one document from the collection that matches the given filter.

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

    filter

    the query filter to apply the the delete operation

    options

    the options to apply to the delete operation

    returns

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

    Since

    1.2

34.  def deleteOne(filter: Bson): SingleObservable[DeleteResult]

    Removes at most one document from the collection that matches the given filter.

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

    filter

    the query filter to apply the the delete operation

    returns

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

35.  def distinct[C](clientSession: ClientSession, fieldName: String, filter: Bson)(implicit ct: ClassTag[C]): DistinctObservable[C]

    Gets the distinct values of the specified field name.

    Gets the distinct values of the specified field name.

    Distinct

    C

    the target type of the observable.

    clientSession

    the client session with which to associate this operation

    fieldName

    the field name

    filter

    the query filter

    returns

    a Observable emitting the sequence of distinct values

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

36.  def distinct[C](clientSession: ClientSession, fieldName: String)(implicit ct: ClassTag[C]): DistinctObservable[C]

    Gets the distinct values of the specified field name.

    Gets the distinct values of the specified field name.

    Distinct

    C

    the target type of the observable.

    clientSession

    the client session with which to associate this operation

    fieldName

    the field name

    returns

    a Observable emitting the sequence of distinct values

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

37.  def distinct[C](fieldName: String, filter: Bson)(implicit ct: ClassTag[C]): DistinctObservable[C]

    Gets the distinct values of the specified field name.

    Gets the distinct values of the specified field name.

    Distinct

    C

    the target type of the observable.

    fieldName

    the field name

    filter

    the query filter

    returns

    a Observable emitting the sequence of distinct values

38.  def distinct[C](fieldName: String)(implicit ct: ClassTag[C]): DistinctObservable[C]

    Gets the distinct values of the specified field name.

    Gets the distinct values of the specified field name.

    Distinct

    C

    the target type of the observable.

    fieldName

    the field name

    returns

    a Observable emitting the sequence of distinct values

39.  lazy val documentClass: Class[TResult]

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

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

    returns

    the default class to cast any documents into

40.  def drop(clientSession: ClientSession): SingleObservable[Completed]

    Drops this collection from the Database.

    Drops this collection from the Database.

    clientSession

    the client session with which to associate this operation

    returns

    a Observable with a single element indicating when the operation has completed Drop Collection

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

41.  def drop(): SingleObservable[Completed]

    Drops this collection from the Database.

    Drops this collection from the Database.

    returns

    a Observable with a single element indicating when the operation has completed Drop Collection

42.  def dropIndex(clientSession: ClientSession, keys: Bson, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]

    Drops the index given the keys used to create it.

    Drops the index given the keys used to create it.

    clientSession

    the client session with which to associate this operation

    keys

    the keys of the index to remove

    dropIndexOptions

    options to use when dropping indexes

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

43.  def dropIndex(clientSession: ClientSession, keys: Bson): SingleObservable[Completed]

    Drops the index given the keys used to create it.

    Drops the index given the keys used to create it.

    clientSession

    the client session with which to associate this operation

    keys

    the keys of the index to remove

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

44.  def dropIndex(clientSession: ClientSession, indexName: String, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]

    Drops the given index.

    Drops the given index.

    Drop Indexes

    clientSession

    the client session with which to associate this operation

    indexName

    the name of the index to remove

    dropIndexOptions

    options to use when dropping indexes

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

45.  def dropIndex(clientSession: ClientSession, indexName: String): SingleObservable[Completed]

    Drops the given index.

    Drops the given index.

    Drop Indexes

    clientSession

    the client session with which to associate this operation

    indexName

    the name of the index to remove

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

46.  def dropIndex(keys: Bson, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]

    Drops the index given the keys used to create it.

    Drops the index given the keys used to create it.

    keys

    the keys of the index to remove

    dropIndexOptions

    options to use when dropping indexes

    returns

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

    Since

    2.2

47.  def dropIndex(keys: Bson): SingleObservable[Completed]

    Drops the index given the keys used to create it.

    Drops the index given the keys used to create it.

    keys

    the keys of the index to remove

    returns

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

48.  def dropIndex(indexName: String, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]

    Drops the given index.

    Drops the given index.

    Drop Indexes

    indexName

    the name of the index to remove

    dropIndexOptions

    options to use when dropping indexes

    returns

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

    Since

    2.2

49.  def dropIndex(indexName: String): SingleObservable[Completed]

    Drops the given index.

    Drops the given index.

    Drop Indexes

    indexName

    the name of the index to remove

    returns

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

50.  def dropIndexes(clientSession: ClientSession, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]

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

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

    Drop Indexes

    clientSession

    the client session with which to associate this operation

    dropIndexOptions

    options to use when dropping indexes

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

51.  def dropIndexes(clientSession: ClientSession): SingleObservable[Completed]

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

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

    Drop Indexes

    clientSession

    the client session with which to associate this operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

52.  def dropIndexes(dropIndexOptions: DropIndexOptions): SingleObservable[Completed]

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

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

    Drop Indexes

    dropIndexOptions

    options to use when dropping indexes

    returns

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

    Since

    2.2

53.  def dropIndexes(): SingleObservable[Completed]

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

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

    Drop Indexes

    returns

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

54.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

55.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

56.  def find[C](clientSession: ClientSession, filter: Bson)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]

    Finds all documents in the collection.

    Finds all documents in the collection.

    Find

    C

    the target document type of the observable.

    clientSession

    the client session with which to associate this operation

    filter

    the query filter

    returns

    the find Observable

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

57.  def find[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]

    Finds all documents in the collection.

    Finds all documents in the collection.

    Find

    C

    the target document type of the observable.

    clientSession

    the client session with which to associate this operation

    returns

    the find Observable

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

58.  def find[C](filter: Bson)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]

    Finds all documents in the collection.

    Finds all documents in the collection.

    Find

    C

    the target document type of the observable.

    filter

    the query filter

    returns

    the find Observable

59.  def find[C]()(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]

    Finds all documents in the collection.

    Finds all documents in the collection.

    Find

    C

    the target document type of the observable.

    returns

    the find Observable

60.  def findOneAndDelete(clientSession: ClientSession, filter: Bson, options: FindOneAndDeleteOptions): SingleObservable[TResult]

    Atomically find a document and remove it.

    Atomically find a document and remove it.

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to find the document with

    options

    the options to apply to the operation

    returns

    a Observable with a single element the document that was removed. If no documents matched the query filter, then null will be returned

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

61.  def findOneAndDelete(clientSession: ClientSession, filter: Bson): SingleObservable[TResult]

    Atomically find a document and remove it.

    Atomically find a document and remove it.

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to find the document with

    returns

    a Observable with a single element the document that was removed. If no documents matched the query filter, then null will be returned

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

62.  def findOneAndDelete(filter: Bson, options: FindOneAndDeleteOptions): SingleObservable[TResult]

    Atomically find a document and remove it.

    Atomically find a document and remove it.

    filter

    the query filter to find the document with

    options

    the options to apply to the operation

    returns

    a Observable with a single element the document that was removed. If no documents matched the query filter, then null will be returned

63.  def findOneAndDelete(filter: Bson): SingleObservable[TResult]

    Atomically find a document and remove it.

    Atomically find a document and remove it.

    filter

    the query filter to find the document with

    returns

    a Observable with a single element the document that was removed. If no documents matched the query filter, then null will be returned

64.  def findOneAndReplace(clientSession: ClientSession, filter: Bson, replacement: TResult, options: FindOneAndReplaceOptions): SingleObservable[TResult]

    Atomically find a document and replace it.

    Atomically find a document and replace it.

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    options

    the options to apply to the operation

    returns

    a 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 null will be returned

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

65.  def findOneAndReplace(clientSession: ClientSession, filter: Bson, replacement: TResult): SingleObservable[TResult]

    Atomically find a document and replace it.

    Atomically find a document and replace it.

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    returns

    a 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 null will be returned

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

66.  def findOneAndReplace(filter: Bson, replacement: TResult, options: FindOneAndReplaceOptions): SingleObservable[TResult]

    Atomically find a document and replace it.

    Atomically find a document and replace it.

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    options

    the options to apply to the operation

    returns

    a 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 null will be returned

67.  def findOneAndReplace(filter: Bson, replacement: TResult): SingleObservable[TResult]

    Atomically find a document and replace it.

    Atomically find a document and replace it.

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    returns

    a 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 null will be returned

68.  def findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Bson, options: FindOneAndUpdateOptions): SingleObservable[TResult]

    Atomically find a document and update it.

    Atomically find a document and update it.

    clientSession

    the client session with which to associate this operation

    filter

    a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

    update

    a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

    options

    the options to apply to the operation

    returns

    a 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 null will be returned

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

69.  def findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Bson): SingleObservable[TResult]

    Atomically find a document and update it.

    Atomically find a document and update it.

    clientSession

    the client session with which to associate this operation

    filter

    a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

    update

    a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

    returns

    a 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 null will be returned

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

70.  def findOneAndUpdate(filter: Bson, update: Bson, options: FindOneAndUpdateOptions): SingleObservable[TResult]

    Atomically find a document and update it.

    Atomically find a document and update it.

    filter

    a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

    update

    a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

    options

    the options to apply to the operation

    returns

    a 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 null will be returned

71.  def findOneAndUpdate(filter: Bson, update: Bson): SingleObservable[TResult]

    Atomically find a document and update it.

    Atomically find a document and update it.

    filter

    a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

    update

    a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

    returns

    a 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 null will be returned

72.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

73.  def insertMany(clientSession: ClientSession, documents: Seq[_ <: TResult], options: InsertManyOptions): SingleObservable[Completed]

    Inserts a batch of documents.

    Inserts a batch of documents. The preferred way to perform bulk inserts is to use the BulkWrite API.

    clientSession

    the client session with which to associate this operation

    documents

    the documents to insert

    options

    the options to apply to the operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

74.  def insertMany(clientSession: ClientSession, documents: Seq[_ <: TResult]): SingleObservable[Completed]

    Inserts a batch of documents.

    Inserts a batch of documents. The preferred way to perform bulk inserts is to use the BulkWrite API.

    clientSession

    the client session with which to associate this operation

    documents

    the documents to insert

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

75.  def insertMany(documents: Seq[_ <: TResult], options: InsertManyOptions): SingleObservable[Completed]

    Inserts a batch of 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.

    documents

    the documents to insert

    options

    the options to apply to the operation

    returns

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

76.  def insertMany(documents: Seq[_ <: TResult]): SingleObservable[Completed]

    Inserts a batch of 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.

    documents

    the documents to insert

    returns

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

77.  def insertOne(clientSession: ClientSession, document: TResult, options: InsertOneOptions): SingleObservable[Completed]

    Inserts the provided document.

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

    clientSession

    the client session with which to associate this operation

    document

    the document to insert

    options

    the options to apply to the operation

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

78.  def insertOne(clientSession: ClientSession, document: TResult): SingleObservable[Completed]

    Inserts the provided document.

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

    clientSession

    the client session with which to associate this operation

    document

    the document to insert

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

79.  def insertOne(document: TResult, options: InsertOneOptions): SingleObservable[Completed]

    Inserts the provided document.

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

    document

    the document to insert

    options

    the options to apply to the operation

    returns

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

    Since

    1.1

80.  def insertOne(document: TResult): SingleObservable[Completed]

    Inserts the provided document.

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

    document

    the document to insert

    returns

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

81.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

82.  def listIndexes[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ListIndexesObservable[C]

    Get all the indexes in this collection.

    Get all the indexes in this collection.

    listIndexes

    C

    the target document type of the observable.

    clientSession

    the client session with which to associate this operation

    returns

    the fluent list indexes interface

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

83.  def listIndexes[C]()(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ListIndexesObservable[C]

    Get all the indexes in this collection.

    Get all the indexes in this collection.

    listIndexes

    C

    the target document type of the observable.

    returns

    the fluent list indexes interface

84.  def mapReduce[C](clientSession: ClientSession, mapFunction: String, reduceFunction: String)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): MapReduceObservable[C]

    Aggregates documents according to the specified map-reduce function.

    Aggregates documents according to the specified map-reduce function.

    C

    the target document type of the observable.

    clientSession

    the client session with which to associate this operation

    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

    a Observable containing the result of the map-reduce operation map-reduce

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

85.  def mapReduce[C](mapFunction: String, reduceFunction: String)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): MapReduceObservable[C]

    Aggregates documents according to the specified map-reduce function.

    Aggregates documents according to the specified map-reduce function.

    C

    the target document type of the observable.

    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

    a Observable containing the result of the map-reduce operation map-reduce

86.  lazy val namespace: MongoNamespace

    Gets the namespace of this collection.

    Gets the namespace of this collection.

    returns

    the namespace

87.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

88.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

89.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

90.  lazy val readConcern: ReadConcern

    Get the read concern for the MongoDatabase.

    Get the read concern for the MongoDatabase.

    returns

    the ReadConcern

    Since

    1.1

91.  lazy val readPreference: ReadPreference

    Get the read preference for the MongoDatabase.

    Get the read preference for the MongoDatabase.

    returns

    the { @link com.mongodb.ReadPreference}

92.  def renameCollection(clientSession: ClientSession, newCollectionNamespace: MongoNamespace, options: RenameCollectionOptions): SingleObservable[Completed]

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename collection

    clientSession

    the client session with which to associate this operation

    newCollectionNamespace

    the name the collection will be renamed to

    options

    the options for renaming a collection

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

93.  def renameCollection(clientSession: ClientSession, newCollectionNamespace: MongoNamespace): SingleObservable[Completed]

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename collection

    clientSession

    the client session with which to associate this operation

    newCollectionNamespace

    the name the collection will be renamed to

    returns

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

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

94.  def renameCollection(newCollectionNamespace: MongoNamespace, options: RenameCollectionOptions): SingleObservable[Completed]

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename collection

    newCollectionNamespace

    the name the collection will be renamed to

    options

    the options for renaming a collection

    returns

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

95.  def renameCollection(newCollectionNamespace: MongoNamespace): SingleObservable[Completed]

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename the collection with oldCollectionName to the newCollectionName.

    Rename collection

    newCollectionNamespace

    the name the collection will be renamed to

    returns

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

96.  def replaceOne(clientSession: ClientSession, filter: Bson, replacement: TResult, options: UpdateOptions): SingleObservable[UpdateResult]

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

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

    Replace

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    options

    the options to apply to the replace operation

    returns

    a Observable with a single element the UpdateResult

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

97.  def replaceOne(clientSession: ClientSession, filter: Bson, replacement: TResult): SingleObservable[UpdateResult]

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

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

    Replace

    clientSession

    the client session with which to associate this operation

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    returns

    a Observable with a single element the UpdateResult

    Since

    2.2

    Note

    Requires MongoDB 3.6 or greater

98.  def replaceOne(filter: Bson, replacement: TResult, options: UpdateOptions): SingleObservable[UpdateResult]

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

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

    Replace

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    options

    the options to apply to the replace operation

    returns

    a Observable with a single element the UpdateResult

99.  def replaceOne(filter: Bson, replacement: TResult): SingleObservable[UpdateResult]

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

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

    Replace

    filter

    the query filter to apply the the replace operation

    replacement

    the replacement document

    returns

    a Observable with a single element the UpdateResult

100.  final def synchronized[T0](arg0: ⇒ T0): T0

     Definition Classes

     AnyRef

101.  def updateMany(clientSession: ClientSession, filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     clientSession

     the client session with which to associate this operation

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     options

     the options to apply to the update operation

     returns

     a Observable with a single element the UpdateResult

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

102.  def updateMany(clientSession: ClientSession, filter: Bson, update: Bson): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     clientSession

     the client session with which to associate this operation

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     returns

     a Observable with a single element the UpdateResult

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

103.  def updateMany(filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     options

     the options to apply to the update operation

     returns

     a Observable with a single element the UpdateResult

104.  def updateMany(filter: Bson, update: Bson): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     returns

     a Observable with a single element the UpdateResult

105.  def updateOne(clientSession: ClientSession, filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     clientSession

     the client session with which to associate this operation

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     options

     the options to apply to the update operation

     returns

     a Observable with a single element the UpdateResult

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

106.  def updateOne(clientSession: ClientSession, filter: Bson, update: Bson): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     clientSession

     the client session with which to associate this operation

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     returns

     a Observable with a single element the UpdateResult

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

107.  def updateOne(filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     options

     the options to apply to the update operation

     returns

     a Observable with a single element the UpdateResult

108.  def updateOne(filter: Bson, update: Bson): SingleObservable[UpdateResult]

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

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

     Updates Update Operators

     filter

     a document describing the query filter, which may not be null. This can be of any type for which a Codec is registered

     update

     a document describing the update, which may not be null. The update to apply must include only update operators. This can be of any type for which a Codec is registered

     returns

     a Observable with a single element the UpdateResult

109.  final def wait(): Unit

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

110.  final def wait(arg0: Long, arg1: Int): Unit

     Definition Classes

     AnyRef

     Annotations

     @throws( ... )

111.  final def wait(arg0: Long): Unit

     Definition Classes

     AnyRef

     Annotations

     @native() @throws( ... )

112.  def watch[C](clientSession: ClientSession, pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]

     Creates a change stream for this collection.

     Creates a change stream for this collection.

     C

     the target document type of the observable.

     clientSession

     the client session with which to associate this operation

     pipeline

     the aggregation pipeline to apply to the change stream

     returns

     the change stream observable

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

113.  def watch[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]

     Creates a change stream for this collection.

     Creates a change stream for this collection.

     C

     the target document type of the observable.

     clientSession

     the client session with which to associate this operation

     returns

     the change stream observable

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

114.  def watch[C](pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]

     Creates a change stream for this collection.

     Creates a change stream for this collection.

     C

     the target document type of the observable.

     pipeline

     the aggregation pipeline to apply to the change stream

     returns

     the change stream observable

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

115.  def watch[C]()(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]

     Creates a change stream for this collection.

     Creates a change stream for this collection.

     C

     the target document type of the observable.

     returns

     the change stream observable

     Since

     2.2

     Note

     Requires MongoDB 3.6 or greater

116.  def withCodecRegistry(codecRegistry: CodecRegistry): MongoCollection[TResult]

     Create a new MongoCollection instance with a different codec registry.

     Create a new MongoCollection instance with a different codec registry.

     codecRegistry

     the new { @link org.bson.codecs.configuration.CodecRegistry} for the collection

     returns

     a new MongoCollection instance with the different codec registry

117.  def withDocumentClass[C]()(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): MongoCollection[C]

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

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

     C

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

     returns

     a new MongoCollection instance with the different default class

118.  def withReadConcern(readConcern: ReadConcern): MongoCollection[TResult]

     Create a new MongoCollection instance with a different read concern.

     Create a new MongoCollection instance with a different read concern.

     readConcern

     the new ReadConcern for the collection

     returns

     a new MongoCollection instance with the different ReadConcern

     Since

     1.1

119.  def withReadPreference(readPreference: ReadPreference): MongoCollection[TResult]

     Create a new MongoCollection instance with a different read preference.

     Create a new MongoCollection instance with a different read preference.

     readPreference

     the new { @link com.mongodb.ReadPreference} for the collection

     returns

     a new MongoCollection instance with the different readPreference

120.  def withWriteConcern(writeConcern: WriteConcern): MongoCollection[TResult]

     Create a new MongoCollection instance with a different write concern.

     Create a new MongoCollection instance with a different write concern.

     writeConcern

     the new { @link com.mongodb.WriteConcern} for the collection

     returns

     a new MongoCollection instance with the different writeConcern

121.  lazy val writeConcern: WriteConcern

     Get the write concern for the MongoDatabase.

     Get the write concern for the MongoDatabase.

     returns

     the { @link com.mongodb.WriteConcern}