17.66. Class WatchEnumerable<TOutput, TInput>
Namespace: ArmoniK.Core.Adapters.MongoDB
Assembly: ArmoniK.Core.Adapters.MongoDB.dll
Class to convert a
public sealed class WatchEnumerable<TOutput, TInput> : IAsyncEnumerable<TOutput>
17.66.1. Type Parameters
TOutput
Output type
TInput
Input type
17.66.2. Inheritance
17.66.3. Implements
17.66.4. Inherited Members
object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()
17.66.5. Constructors
17.66.5.1. WatchEnumerable(IChangeStreamCursor<TInput>, Func<TInput, TOutput>)
Initializes a TInput into TOutput
public WatchEnumerable(IChangeStreamCursor<TInput> cursor, Func<TInput, TOutput> converter)
17.66.5.1.1. Parameters
cursor IChangeStreamCursor<TInput>
Input change stream cursor
converter Func<TInput, TOutput>
Func to convert the input into the output
17.66.6. Methods
17.66.6.1. GetAsyncEnumerator(CancellationToken)
Returns an enumerator that iterates asynchronously through the collection.
public IAsyncEnumerator<TOutput> GetAsyncEnumerator(CancellationToken cancellationToken = default)
17.66.6.1.1. Parameters
cancellationToken CancellationToken
A
17.66.6.1.2. Returns
IAsyncEnumerator<TOutput>
An enumerator that can be used to iterate asynchronously through the collection.