30.65. Class WatchEnumerator<TOutput, TInput>
Namespace: ArmoniK.Core.Adapters.MongoDB
Assembly: ArmoniK.Core.Adapters.MongoDB.dll
Class to convert a
public sealed class WatchEnumerator<TOutput, TInput> : IAsyncEnumerator<TOutput>, IAsyncDisposable
30.65.1. Type Parameters
TOutput
Output type
TInput
Input type
30.65.2. Inheritance
30.65.3. Implements
30.65.4. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()
30.65.5. Constructors
30.65.5.1. WatchEnumerator(IChangeStreamCursor<TInput>, Func<TInput, TOutput>, CancellationToken)
Initializes a TInput into TOutput
public WatchEnumerator(IChangeStreamCursor<TInput> cursor, Func<TInput, TOutput> converter, CancellationToken cancellationToken)
30.65.5.1.1. Parameters
cursor IChangeStreamCursor<TInput>
Input change stream cursor
converter Func<TInput, TOutput>
Func to convert the input into the output
cancellationToken CancellationToken
Token used to cancel the execution of the method
30.65.6. Properties
30.65.6.1. Current
Gets the element in the collection at the current position of the enumerator.
public TOutput Current { get; }
30.65.6.1.1. Property Value
TOutput
30.65.7. Methods
30.65.7.1. DisposeAsync()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.
public ValueTask DisposeAsync()
30.65.7.1.1. Returns
A task that represents the asynchronous dispose operation.
30.65.7.2. MoveNextAsync()
Advances the enumerator asynchronously to the next element of the collection.
public ValueTask<bool> MoveNextAsync()
30.65.7.2.1. Returns
A true if the enumerator
was successfully advanced to the next element, or false if the enumerator has passed the end
of the collection.