Mongo Scala Driver - org.mongodb.scala.MongoCollection (original) (raw)

case class MongoCollection[TResult](wrapped: com.mongodb.async.client.MongoCollection[TResult]) extends Product with Serializable

 

Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. MongoCollection

2. Serializable

3. Product

4. Equals

5. AnyRef

6. Any

7. Hide All

8. Show All

Visibility

1. Public
2. Protected

Value Members

1.  final def !=(arg0: Any): Boolean
2.  final def ##(): Int
3.  final def ==(arg0: Any): Boolean
4.  def aggregate[C](clientSession: ClientSession, pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): AggregateObservable[C]
5.  def aggregate[C](pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): AggregateObservable[C]
6.  final def asInstanceOf[T0]: T0
7.  def bulkWrite(clientSession: ClientSession, requests: Seq[_ <: WriteModel[_ <: TResult]], options: BulkWriteOptions): SingleObservable[BulkWriteResult]
8.  def bulkWrite(clientSession: ClientSession, requests: Seq[_ <: WriteModel[_ <: TResult]]): SingleObservable[BulkWriteResult]
9.  def bulkWrite(requests: Seq[_ <: WriteModel[_ <: TResult]], options: BulkWriteOptions): SingleObservable[BulkWriteResult]
10.  def bulkWrite(requests: Seq[_ <: WriteModel[_ <: TResult]]): SingleObservable[BulkWriteResult]
11.  def clone(): AnyRef
12.  lazy val codecRegistry: CodecRegistry
13.  def countDocuments(clientSession: ClientSession, filter: Bson, options: CountOptions): SingleObservable[Long]
14.  def countDocuments(clientSession: ClientSession, filter: Bson): SingleObservable[Long]
15.  def countDocuments(clientSession: ClientSession): SingleObservable[Long]
16.  def countDocuments(filter: Bson, options: CountOptions): SingleObservable[Long]
17.  def countDocuments(filter: Bson): SingleObservable[Long]
18.  def countDocuments(): SingleObservable[Long]
19.  def createIndex(clientSession: ClientSession, key: Bson, options: IndexOptions): SingleObservable[String]
20.  def createIndex(clientSession: ClientSession, key: Bson): SingleObservable[String]
21.  def createIndex(key: Bson, options: IndexOptions): SingleObservable[String]
22.  def createIndex(key: Bson): SingleObservable[String]
23.  def createIndexes(clientSession: ClientSession, models: Seq[IndexModel], createIndexOptions: CreateIndexOptions): Observable[String]
24.  def createIndexes(clientSession: ClientSession, models: Seq[IndexModel]): Observable[String]
25.  def createIndexes(models: Seq[IndexModel], createIndexOptions: CreateIndexOptions): Observable[String]
26.  def createIndexes(models: Seq[IndexModel]): Observable[String]
27.  def deleteMany(clientSession: ClientSession, filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]
28.  def deleteMany(clientSession: ClientSession, filter: Bson): SingleObservable[DeleteResult]
29.  def deleteMany(filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]
30.  def deleteMany(filter: Bson): SingleObservable[DeleteResult]
31.  def deleteOne(clientSession: ClientSession, filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]
32.  def deleteOne(clientSession: ClientSession, filter: Bson): SingleObservable[DeleteResult]
33.  def deleteOne(filter: Bson, options: DeleteOptions): SingleObservable[DeleteResult]
34.  def deleteOne(filter: Bson): SingleObservable[DeleteResult]
35.  def distinct[C](clientSession: ClientSession, fieldName: String, filter: Bson)(implicit ct: ClassTag[C]): DistinctObservable[C]
36.  def distinct[C](clientSession: ClientSession, fieldName: String)(implicit ct: ClassTag[C]): DistinctObservable[C]
37.  def distinct[C](fieldName: String, filter: Bson)(implicit ct: ClassTag[C]): DistinctObservable[C]
38.  def distinct[C](fieldName: String)(implicit ct: ClassTag[C]): DistinctObservable[C]
39.  lazy val documentClass: Class[TResult]
40.  def drop(clientSession: ClientSession): SingleObservable[Completed]
41.  def drop(): SingleObservable[Completed]
42.  def dropIndex(clientSession: ClientSession, keys: Bson, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]
43.  def dropIndex(clientSession: ClientSession, keys: Bson): SingleObservable[Completed]
44.  def dropIndex(clientSession: ClientSession, indexName: String, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]
45.  def dropIndex(clientSession: ClientSession, indexName: String): SingleObservable[Completed]
46.  def dropIndex(keys: Bson, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]
47.  def dropIndex(keys: Bson): SingleObservable[Completed]
48.  def dropIndex(indexName: String, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]
49.  def dropIndex(indexName: String): SingleObservable[Completed]
50.  def dropIndexes(clientSession: ClientSession, dropIndexOptions: DropIndexOptions): SingleObservable[Completed]
51.  def dropIndexes(clientSession: ClientSession): SingleObservable[Completed]
52.  def dropIndexes(dropIndexOptions: DropIndexOptions): SingleObservable[Completed]
53.  def dropIndexes(): SingleObservable[Completed]
54.  final def eq(arg0: AnyRef): Boolean
55.  def estimatedDocumentCount(options: EstimatedDocumentCountOptions): SingleObservable[Long]
56.  def estimatedDocumentCount(): SingleObservable[Long]
57.  def finalize(): Unit
58.  def find[C](clientSession: ClientSession, filter: Bson)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]
59.  def find[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]
60.  def find[C](filter: Bson)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]
61.  def find[C]()(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): FindObservable[C]
62.  def findOneAndDelete(clientSession: ClientSession, filter: Bson, options: FindOneAndDeleteOptions): SingleObservable[TResult]
63.  def findOneAndDelete(clientSession: ClientSession, filter: Bson): SingleObservable[TResult]
64.  def findOneAndDelete(filter: Bson, options: FindOneAndDeleteOptions): SingleObservable[TResult]
65.  def findOneAndDelete(filter: Bson): SingleObservable[TResult]
66.  def findOneAndReplace(clientSession: ClientSession, filter: Bson, replacement: TResult, options: FindOneAndReplaceOptions): SingleObservable[TResult]
67.  def findOneAndReplace(clientSession: ClientSession, filter: Bson, replacement: TResult): SingleObservable[TResult]
68.  def findOneAndReplace(filter: Bson, replacement: TResult, options: FindOneAndReplaceOptions): SingleObservable[TResult]
69.  def findOneAndReplace(filter: Bson, replacement: TResult): SingleObservable[TResult]
70.  def findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Seq[Bson], options: FindOneAndUpdateOptions): SingleObservable[TResult]
71.  def findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Seq[Bson]): SingleObservable[TResult]
72.  def findOneAndUpdate(filter: Bson, update: Seq[Bson], options: FindOneAndUpdateOptions): SingleObservable[TResult]
73.  def findOneAndUpdate(filter: Bson, update: Seq[Bson]): SingleObservable[TResult]
74.  def findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Bson, options: FindOneAndUpdateOptions): SingleObservable[TResult]
75.  def findOneAndUpdate(clientSession: ClientSession, filter: Bson, update: Bson): SingleObservable[TResult]
76.  def findOneAndUpdate(filter: Bson, update: Bson, options: FindOneAndUpdateOptions): SingleObservable[TResult]
77.  def findOneAndUpdate(filter: Bson, update: Bson): SingleObservable[TResult]
78.  final def getClass(): Class[_ <: AnyRef]
79.  def insertMany(clientSession: ClientSession, documents: Seq[_ <: TResult], options: InsertManyOptions): SingleObservable[Completed]
80.  def insertMany(clientSession: ClientSession, documents: Seq[_ <: TResult]): SingleObservable[Completed]
81.  def insertMany(documents: Seq[_ <: TResult], options: InsertManyOptions): SingleObservable[Completed]
82.  def insertMany(documents: Seq[_ <: TResult]): SingleObservable[Completed]
83.  def insertOne(clientSession: ClientSession, document: TResult, options: InsertOneOptions): SingleObservable[Completed]
84.  def insertOne(clientSession: ClientSession, document: TResult): SingleObservable[Completed]
85.  def insertOne(document: TResult, options: InsertOneOptions): SingleObservable[Completed]
86.  def insertOne(document: TResult): SingleObservable[Completed]
87.  final def isInstanceOf[T0]: Boolean
88.  def listIndexes[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ListIndexesObservable[C]
89.  def listIndexes[C]()(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): ListIndexesObservable[C]
90.  def mapReduce[C](clientSession: ClientSession, mapFunction: String, reduceFunction: String)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): MapReduceObservable[C]
91.  def mapReduce[C](mapFunction: String, reduceFunction: String)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): MapReduceObservable[C]
92.  lazy val namespace: MongoNamespace
93.  final def ne(arg0: AnyRef): Boolean
94.  final def notify(): Unit
95.  final def notifyAll(): Unit
96.  def productElementNames: Iterator[String]
97.  lazy val readConcern: ReadConcern
98.  lazy val readPreference: ReadPreference
99.  def renameCollection(clientSession: ClientSession, newCollectionNamespace: MongoNamespace, options: RenameCollectionOptions): SingleObservable[Completed]
100.  def renameCollection(clientSession: ClientSession, newCollectionNamespace: MongoNamespace): SingleObservable[Completed]
101.  def renameCollection(newCollectionNamespace: MongoNamespace, options: RenameCollectionOptions): SingleObservable[Completed]
102.  def renameCollection(newCollectionNamespace: MongoNamespace): SingleObservable[Completed]
103.  def replaceOne(clientSession: ClientSession, filter: Bson, replacement: TResult, options: ReplaceOptions): SingleObservable[UpdateResult]
104.  def replaceOne(filter: Bson, replacement: TResult, options: ReplaceOptions): SingleObservable[UpdateResult]
105.  def replaceOne(clientSession: ClientSession, filter: Bson, replacement: TResult): SingleObservable[UpdateResult]
106.  def replaceOne(filter: Bson, replacement: TResult): SingleObservable[UpdateResult]
107.  final def synchronized[T0](arg0: => T0): T0
108.  def updateMany(clientSession: ClientSession, filter: Bson, update: Seq[Bson], options: UpdateOptions): SingleObservable[UpdateResult]
109.  def updateMany(clientSession: ClientSession, filter: Bson, update: Seq[Bson]): SingleObservable[UpdateResult]
110.  def updateMany(filter: Bson, update: Seq[Bson], options: UpdateOptions): SingleObservable[UpdateResult]
111.  def updateMany(filter: Bson, update: Seq[Bson]): SingleObservable[UpdateResult]
112.  def updateMany(clientSession: ClientSession, filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]
113.  def updateMany(clientSession: ClientSession, filter: Bson, update: Bson): SingleObservable[UpdateResult]
114.  def updateMany(filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]
115.  def updateMany(filter: Bson, update: Bson): SingleObservable[UpdateResult]
116.  def updateOne(clientSession: ClientSession, filter: Bson, update: Seq[Bson], options: UpdateOptions): SingleObservable[UpdateResult]
117.  def updateOne(clientSession: ClientSession, filter: Bson, update: Seq[Bson]): SingleObservable[UpdateResult]
118.  def updateOne(filter: Bson, update: Seq[Bson], options: UpdateOptions): SingleObservable[UpdateResult]
119.  def updateOne(filter: Bson, update: Seq[Bson]): SingleObservable[UpdateResult]
120.  def updateOne(clientSession: ClientSession, filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]
121.  def updateOne(clientSession: ClientSession, filter: Bson, update: Bson): SingleObservable[UpdateResult]
122.  def updateOne(filter: Bson, update: Bson, options: UpdateOptions): SingleObservable[UpdateResult]
123.  def updateOne(filter: Bson, update: Bson): SingleObservable[UpdateResult]
124.  final def wait(): Unit
125.  final def wait(arg0: Long, arg1: Int): Unit
126.  final def wait(arg0: Long): Unit
127.  def watch[C](clientSession: ClientSession, pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]
128.  def watch[C](clientSession: ClientSession)(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]
129.  def watch[C](pipeline: Seq[Bson])(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]
130.  def watch[C]()(implicit e: DefaultsTo[C, TResult], ct: ClassTag[C]): ChangeStreamObservable[C]
131.  def withCodecRegistry(codecRegistry: CodecRegistry): MongoCollection[TResult]
132.  def withDocumentClass[C]()(implicit e: DefaultsTo[C, Document], ct: ClassTag[C]): MongoCollection[C]
133.  def withReadConcern(readConcern: ReadConcern): MongoCollection[TResult]
134.  def withReadPreference(readPreference: ReadPreference): MongoCollection[TResult]
135.  def withWriteConcern(writeConcern: WriteConcern): MongoCollection[TResult]
136.  lazy val writeConcern: WriteConcern

Deprecated Value Members

1.  def count(clientSession: ClientSession, filter: Bson, options: CountOptions): SingleObservable[Long]
2.  def count(clientSession: ClientSession, filter: Bson): SingleObservable[Long]
3.  def count(clientSession: ClientSession): SingleObservable[Long]
4.  def count(filter: Bson, options: CountOptions): SingleObservable[Long]
5.  def count(filter: Bson): SingleObservable[Long]
6.  def count(): SingleObservable[Long]
7.  def replaceOne(clientSession: ClientSession, filter: Bson, replacement: TResult, options: UpdateOptions): SingleObservable[UpdateResult]
8.  def replaceOne(filter: Bson, replacement: TResult, options: UpdateOptions): SingleObservable[UpdateResult]

Ungrouped