MongoDB driver for Kotlin (coroutines) • opensavvy.ktmongo.coroutines • MongoAggregationPipeline
MongoAggregationPipeline¶
class MongoAggregationPipeline<Output : Any> : LazyMongoIterable<Output>
Functions¶
asFlow¶
open override fun asFlow(): <Document>
Streams the results of this response into a Flow.
asIterable¶
open override fun asIterable(): MongoIterable<Output>
asSequence¶
open fun asSequence(): <Document>
embedInUnionWith¶
open fun embedInUnionWith(writer: ):
first¶
Returns the first document found by this query, or throws an exception.
firstOrNull¶
open suspend override fun firstOrNull(): Output?
Returns the first document found by this query, or null if none were found.
forEach¶
Executes action for each document returned by this query.
limit¶
open fun limit(amount: Int): MongoAggregationPipeline<Output>
open fun limit(amount: Long): MongoAggregationPipeline<Output>
match¶
open fun match(filter: <Output>.() -> Unit): MongoAggregationPipeline<Output>
project¶
open fun project(block: <Output>.() -> Unit): MongoAggregationPipeline<Output>
reinterpret¶
open fun <New : Any> reinterpret(): MongoAggregationPipeline<New>
sample¶
open fun sample(size: Int): MongoAggregationPipeline<Output>
set¶
open fun set(block: <Output>.() -> Unit): MongoAggregationPipeline<Output>
skip¶
open fun skip(amount: Int): MongoAggregationPipeline<Output>
open fun skip(amount: Long): MongoAggregationPipeline<Output>
sort¶
open fun sort(block: <Output>.() -> Unit): MongoAggregationPipeline<Output>
toList¶
Reads the entirety of this response into a List.
toSequence¶
open fun toSequence(): <Document>
toSet¶
Reads the entirety of this response into a Set.
unionWith¶
open fun unionWith(other: <Output>): MongoAggregationPipeline<Output>
unset¶
open fun unset(block: <Output>.() -> Unit): MongoAggregationPipeline<Output>
withStage¶
open fun withStage(stage: ): MongoAggregationPipeline<Output>