CoroutineAggregatePublisher |
Coroutine wrapper around AggregatePublisher. class CoroutineAggregatePublisher<T : Any> : CoroutinePublisher<T> |
CoroutineChangeStreamPublisher |
Coroutine wrapper around ChangeStreamPublisher. class CoroutineChangeStreamPublisher<TResult : Any> : CoroutinePublisher<ChangeStreamDocument<TResult>> |
CoroutineClient |
A wrapper around MongoClient. Provides coroutine methods for Reactive Streams driver. class CoroutineClient : Closeable |
CoroutineCollection |
A wrapper around MongoCollection. Provides coroutine methods for Reactive Streams driver. class CoroutineCollection<T : Any> |
CoroutineDatabase |
A wrapper around MongoDatabase. Provides coroutine methods for Reactive Streams driver. class CoroutineDatabase |
CoroutineDistinctPublisher |
Coroutine wrapper around CoroutineDistinctPublisher. class CoroutineDistinctPublisher<T : Any> : CoroutinePublisher<T> |
CoroutineFindPublisher |
Coroutine wrapper around CoroutineFindPublisher. class CoroutineFindPublisher<T : Any> : CoroutinePublisher<T> |
CoroutineListCollectionsPublisher |
Coroutine wrapper around ListCollectionsPublisher. class CoroutineListCollectionsPublisher<TResult : Any> : CoroutinePublisher<TResult> |
CoroutineListIndexesPublisher |
Coroutine wrapper around CoroutineListIndexesPublisher. class CoroutineListIndexesPublisher<T : Any> : CoroutinePublisher<T> |
CoroutineMapReducePublisher |
Coroutine wrapper around MapReducePublisher. class CoroutineMapReducePublisher<T : Any> : CoroutinePublisher<T> |
CoroutinePublisher |
Coroutine wrapper around Publisher. open class CoroutinePublisher<T : Any> |
aggregate |
Aggregates documents according to the specified aggregation pipeline. If the pipeline ends with a $out stage, the returned iterable will be a query of the collection that the aggregation was written to. Note that in this case the pipeline will be executed even if the iterable is never iterated. fun <T : Any> CoroutineCollection<*>.aggregate(vararg pipeline: String): CoroutineAggregatePublisher<T>fun <T : Any> CoroutineCollection<*>.aggregate(vararg pipeline: Bson): CoroutineAggregatePublisher<T> |
bulkWrite |
Executes a mix of inserts, updates, replaces, and deletes. suspend fun <T : Any> CoroutineCollection<T>.bulkWrite(clientSession: ClientSession, vararg requests: String, options: BulkWriteOptions = BulkWriteOptions()): BulkWriteResultsuspend fun <T : Any> CoroutineCollection<T>.bulkWrite(vararg requests: String, options: BulkWriteOptions = BulkWriteOptions()): BulkWriteResult |
insertOne |
Inserts the provided document. If the document is missing an identifier, the driver should generate one. suspend fun <T : Any> CoroutineCollection<T>.insertOne(document: String, options: InsertOneOptions = InsertOneOptions()): InsertOneResultsuspend fun <T : Any> CoroutineCollection<T>.insertOne(clientSession: ClientSession, document: String, options: InsertOneOptions = InsertOneOptions()): InsertOneResult |
projection |
Returns the specified field for all matching documents. fun <F : Any> CoroutineCollection<*>.projection(property: KProperty<F?>, query: Bson = EMPTY_BSON, options: (CoroutineFindPublisher<SingleProjection<F>>) -> CoroutineFindPublisher<SingleProjection<F>> = { it }): CoroutineFindPublisher<F>
Returns the specified two fields for all matching documents. fun <F1 : Any, F2 : Any> CoroutineCollection<*>.projection(property1: KProperty<F1?>, property2: KProperty<F2?>, query: Bson = EMPTY_BSON, options: (CoroutineFindPublisher<PairProjection<F1, F2>>) -> CoroutineFindPublisher<PairProjection<F1, F2>> = { it }): CoroutineFindPublisher<Pair<F1?, F2?>>
Returns the specified three fields for all matching documents. fun <F1 : Any, F2 : Any, F3 : Any> CoroutineCollection<*>.projection(property1: KProperty<F1?>, property2: KProperty<F2?>, property3: KProperty<F3?>, query: Bson = EMPTY_BSON, options: (CoroutineFindPublisher<TripleProjection<F1, F2, F3>>) -> CoroutineFindPublisher<TripleProjection<F1, F2, F3>> = { it }): CoroutineFindPublisher<Triple<F1?, F2?, F3?>> |
replaceOne |
Replace a document in the collection according to the specified arguments. suspend fun <T : Any> CoroutineCollection<T>.replaceOne(replacement: T, options: ReplaceOptions = ReplaceOptions()): UpdateResult |
singleResult |
Coroutine wrapper for SingleResultCallback suspend fun <T : Any> singleResult(callback: (SingleResultCallback<T>) -> Unit): T? |
updateOne |
Update a single document in the collection according to the specified arguments. suspend fun <T : Any> CoroutineCollection<T>.updateOne(target: T, options: UpdateOptions = UpdateOptions(), updateOnlyNotNullProperties: Boolean = UpdateConfiguration.updateOnlyNotNullProperties): UpdateResultsuspend fun <T : Any> CoroutineCollection<T>.updateOne(clientSession: ClientSession, target: T, options: UpdateOptions = UpdateOptions(), updateOnlyNotNullProperties: Boolean = UpdateConfiguration.updateOnlyNotNullProperties): UpdateResult |