Table of Contents

Class ChangeStreamOperation<TResult>

Namespace
MongoDB.Driver.Core.Operations
Assembly
MongoDB.Driver.Core.dll

A change stream operation.

public class ChangeStreamOperation<TResult> : IChangeStreamOperation<TResult>, IReadOperation<IChangeStreamCursor<TResult>>

Type Parameters

TResult

The type of the result values.

Inheritance
ChangeStreamOperation<TResult>
Implements
Inherited Members
Extension Methods

Constructors

ChangeStreamOperation(CollectionNamespace, IEnumerable<BsonDocument>, IBsonSerializer<TResult>, MessageEncoderSettings)

Initializes a new instance of the ChangeStreamOperation<TResult> class.

ChangeStreamOperation(DatabaseNamespace, IEnumerable<BsonDocument>, IBsonSerializer<TResult>, MessageEncoderSettings)

Initializes a new instance of the ChangeStreamOperation<TResult> class.

ChangeStreamOperation(IEnumerable<BsonDocument>, IBsonSerializer<TResult>, MessageEncoderSettings)

Initializes a new instance of the ChangeStreamOperation<TResult> class.

Properties

BatchSize

Gets or sets the size of the batch.

Collation

Gets or sets the collation.

CollectionNamespace

Gets the collection namespace.

Comment

Gets or sets the comment.

DatabaseNamespace

Gets the database namespace.

FullDocument

Gets or sets the full document option.

FullDocumentBeforeChange

Gets or sets the full document before change option.

MaxAwaitTime

Gets or sets the maximum await time.

MessageEncoderSettings

Gets the message encoder settings.

Pipeline

Gets the pipeline.

ReadConcern

Gets or sets the read concern.

ResultSerializer

Gets the result serializer.

ResumeAfter

Gets or sets the resume after value.

RetryRequested

Gets or sets a value indicating whether to retry.

ShowExpandedEvents

Gets or sets whether the change stream should show expanded events (MongoDB 6.0 and later).

StartAfter

Gets or sets the start after value.

StartAtOperationTime

Gets or sets the start at operation time.

Methods

Execute(IReadBinding, CancellationToken)

Executes the operation.

ExecuteAsync(IReadBinding, CancellationToken)

Executes the operation.

Resume(IReadBinding, CancellationToken)

Resumes the operation after a resume token.

ResumeAsync(IReadBinding, CancellationToken)

Resumes the operation after a resume token.