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

MongoAggregationPipeline

class MongoAggregationPipeline<Output : Any> : LazyMongoIterable<Output> (source)

Functions

asFlow

open override fun asFlow(): <Error class: unknown class><Document>

Streams the results of this response into a Flow.

asIterable

open override fun asIterable(): MongoIterable<Output>

asSequence

open fun ~~asSequence~~(): <Error class: unknown class><Document>

embedInUnionWith

open fun embedInUnionWith(writer: <Error class: unknown class>): <Error class: unknown class>

first

open suspend fun first(): Output

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

open suspend override fun forEach(action: suspend (Output) -> Unit)

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: <Error class: unknown class><Output>.() -> Unit): MongoAggregationPipeline<Output>

project

open fun project(block: <Error class: unknown class><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: <Error class: unknown class><Output>.() -> Unit): MongoAggregationPipeline<Output>

skip

open fun skip(amount: Int): MongoAggregationPipeline<Output>

open fun skip(amount: Long): MongoAggregationPipeline<Output>

sort

open fun sort(block: <Error class: unknown class><Output>.() -> Unit): MongoAggregationPipeline<Output>

toList

open suspend fun toList(): List<Output>

Reads the entirety of this response into a List.

toSequence

open fun ~~toSequence~~(): <Error class: unknown class><Document>

toSet

open suspend fun toSet(): Set<Output>

Reads the entirety of this response into a Set.

unionWith

open fun unionWith(other: <Error class: unknown class><Output>): MongoAggregationPipeline<Output>

unset

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

withStage

open fun withStage(stage: <Error class: unknown class>): MongoAggregationPipeline<Output>