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: object

ChangeStreamOperation<TResult>

Implements: IChangeStreamOperation<TResult>

IReadOperation<IChangeStreamCursor<TResult>>

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods: OperationExtensionMethods.ExecuteAsync<TResult>(IReadOperation<TResult>, IChannelSourceHandle, ReadPreference, ICoreSessionHandle, CancellationToken)

OperationExtensionMethods.Execute<TResult>(IReadOperation<TResult>, IChannelSourceHandle, ReadPreference, ICoreSessionHandle, CancellationToken)

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.