MongoDB driver for Kotlin (coroutines) • opensavvy.ktmongo.coroutines • MongoAggregationPipeline

MongoAggregationPipeline

class MongoAggregationPipeline<Output : Any> : LazyMongoIterable<Output> 

Functions

asFlow

inline fun <Document : Any> LazyMongoIterable<Document>.asFlow(): <Document>

asIterable

open override fun asIterable(documentType: Class<Output>): MongoIterable<Output>

asIterable

inline fun <Document : Any> LazyMongoIterable<Document>.asIterable(): MongoIterable<Document>

embedInUnionWith

open fun embedInUnionWith(writer: ): 

first

inline suspend fun <Document : Any> LazyMongoIterable<Document>.first(): Document

firstOrNull

inline suspend fun <Document : Any> LazyMongoIterable<Document>.firstOrNull(): Document?

forEach

inline suspend fun <Document : Any> LazyMongoIterable<Document>.forEach(noinline action: suspend (Document) -> Unit)

group

open fun <Out : Any> group(block: <Output, Out>.() -> Unit): MongoAggregationPipeline<Out>

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

inline suspend fun <Document : Any> LazyMongoIterable<Document>.toList(): List<Document>

toSet

inline suspend fun <Document : Any> LazyMongoIterable<Document>.toSet(): Set<Document>

unionWith

open fun unionWith(other: <Output>): MongoAggregationPipeline<Output>

unset

open fun unset(block: <Output>.() -> Unit): MongoAggregationPipeline<Output>

withStage

open fun withStage(stage: ): MongoAggregationPipeline<Output>