Class ParallelDataflowBlockExtensions

Namespace

CounterpointCollective.Dataflow

Assembly

Dataflow.Composable.dll

public static class ParallelDataflowBlockExtensions

Inheritance

object

ParallelDataflowBlockExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Par<I>(IPropagatorBlock<I, I>[])

public static IPropagatorBlock<I, I> Par<I>(this IPropagatorBlock<I, I>[] blocks)

Parameters

blocks IPropagatorBlock<I, I>[]

Returns

IPropagatorBlock<I, I>

Type Parameters

I

Par<I>(IPropagatorBlock<I, I>[], GuaranteedBroadcastBlockOptions)

public static IPropagatorBlock<I, I> Par<I>(this IPropagatorBlock<I, I>[] blocks, GuaranteedBroadcastBlockOptions options)

Parameters

blocks IPropagatorBlock<I, I>[]

options GuaranteedBroadcastBlockOptions

Returns

IPropagatorBlock<I, I>

Type Parameters

I

Par<I, T, O>(IPropagatorBlock<I, T>[], Func<T[], O>, GuaranteedBroadcastBlockOptions)

public static ParallelBlock<I, T, O> Par<I, T, O>(this IPropagatorBlock<I, T>[] blocks, Func<T[], O> recombine, GuaranteedBroadcastBlockOptions options)

Parameters

blocks IPropagatorBlock<I, T>[]

recombine Func<T[], O>

options GuaranteedBroadcastBlockOptions

Returns

ParallelBlock<I, T, O>

Type Parameters

I

T

O

Par<TInput, T1, T2, TOutput>(IPropagatorBlock<TInput, T1>, IPropagatorBlock<TInput, T2>, Func<T1, T2, TOutput>, GuaranteedBroadcastBlockOptions)

public static IPropagatorBlock<TInput, TOutput> Par<TInput, T1, T2, TOutput>(this IPropagatorBlock<TInput, T1> p1, IPropagatorBlock<TInput, T2> p2, Func<T1, T2, TOutput> f, GuaranteedBroadcastBlockOptions options)

Parameters

p1 IPropagatorBlock<TInput, T1>

p2 IPropagatorBlock<TInput, T2>

f Func<T1, T2, TOutput>

options GuaranteedBroadcastBlockOptions

Returns

IPropagatorBlock<TInput, TOutput>

Type Parameters

TInput

T1

T2

TOutput