Class IAsyncEnumerableExtensions

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public static class IAsyncEnumerableExtensions

Inheritance

object

IAsyncEnumerableExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

AsSourceBlock<I>(IAsyncEnumerable<I>)

public static BufferBlock<I> AsSourceBlock<I>(this IAsyncEnumerable<I> source)

Parameters

source IAsyncEnumerable<I>

Returns

BufferBlock<I>

Type Parameters

I

AsSourceBlock<I>(IAsyncEnumerable<I>, bool)

public static BufferBlock<I> AsSourceBlock<I>(this IAsyncEnumerable<I> source, bool complete)

Parameters

source IAsyncEnumerable<I>

complete bool

Returns

BufferBlock<I>

Type Parameters

I

AsSourceBlock<I>(IAsyncEnumerable<I>, DataflowBlockOptions)

public static BufferBlock<I> AsSourceBlock<I>(this IAsyncEnumerable<I> source, DataflowBlockOptions options)

Parameters

source IAsyncEnumerable<I>

options DataflowBlockOptions

Returns

BufferBlock<I>

Type Parameters

I

AsSourceBlock<I>(IAsyncEnumerable<I>, DataflowBlockOptions, bool)

public static BufferBlock<I> AsSourceBlock<I>(this IAsyncEnumerable<I> source, DataflowBlockOptions options, bool complete)

Parameters

source IAsyncEnumerable<I>

options DataflowBlockOptions

complete bool

Returns

BufferBlock<I>

Type Parameters

I

FeedTo<T>(IAsyncEnumerable<T>, ITargetBlock<T>, bool, CancellationToken)

public static Task FeedTo<T>(this IAsyncEnumerable<T> source, ITargetBlock<T> target, bool complete, CancellationToken cancel = default)

Parameters

source IAsyncEnumerable<T>

target ITargetBlock<T>

complete bool

cancel CancellationToken

Returns

Task

Type Parameters

T

FeedTo<T>(IAsyncEnumerable<T>, ITargetBlock<T>, CancellationToken)

public static Task FeedTo<T>(this IAsyncEnumerable<T> source, ITargetBlock<T> target, CancellationToken cancel = default)

Parameters

source IAsyncEnumerable<T>

target ITargetBlock<T>

cancel CancellationToken

Returns

Task

Type Parameters

T