PipelineDefinitionBuilder.ChangeStream<TInput, TIntermediate> Method

Appends a $changeStream stage to the pipeline. Normally you would prefer to use the Watch method of IMongoCollection<TDocument>. Only use this method if subsequent stages project away the resume token (the _id) or you don't want the resulting cursor to automatically resume.

Namespace: MongoDB.Driver
Assembly: MongoDB.Driver (in MongoDB.Driver.dll) Version: 2.21.0+5a9c3311e158910b88195f290e6d4b1b2715d2b2

Syntax

Copy

public static PipelineDefinition<TInput, ChangeStreamDocument<TIntermediate>> ChangeStream<TInput, TIntermediate>(
	this PipelineDefinition<TInput, TIntermediate> pipeline,
	ChangeStreamStageOptions options = null
)

<ExtensionAttribute>
Public Shared Function ChangeStream(Of TInput, TIntermediate) ( 
	pipeline As PipelineDefinition(Of TInput, TIntermediate),
	Optional options As ChangeStreamStageOptions = Nothing
) As PipelineDefinition(Of TInput, ChangeStreamDocument(Of TIntermediate))

[<ExtensionAttribute>]
static member ChangeStream : 
        pipeline : PipelineDefinition<'TInput, 'TIntermediate> * 
        ?options : ChangeStreamStageOptions 
(* Defaults:
        let _options = defaultArg options null
*)
-> PipelineDefinition<'TInput, ChangeStreamDocument<'TIntermediate>>

Parameters

pipeline: Type: MongoDB.Driver.PipelineDefinition<TInput, TIntermediate>
The pipeline.
options (Optional): Type: MongoDB.Driver.ChangeStreamStageOptions
The options.

Type Parameters

TInput: The type of the input documents.
TIntermediate: The type of the intermediate documents.

Return Value

Type: PipelineDefinition<TInput, ChangeStreamDocument<TIntermediate>>
The fluent aggregate interface.

Usage Note

In Visual Basic and C#, you can call this method as an instance method on any object of type PipelineDefinition<TInput, TIntermediate>. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).

Reference

PipelineDefinitionBuilder Class