MongoDB driver for Kotlin (synchronous)/opensavvy.ktmongo.sync/MongoAggregationPipeline

MongoAggregationPipeline

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

Functions

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 fun first(): Output

Returns the first document found by this query, or throws an exception.

firstOrNull

open override fun firstOrNull(): Output?

Returns the first document found by this query, or null if none were found.

forEach

open override fun forEach(action: (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 fun toList(): List<Output>

Reads the entirety of this response into a List.

toSequence

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

toSet

open 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>