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
-
IChangeStreamOperation<TResult>IReadOperation<IChangeStreamCursor<TResult>>
- 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.