Class DataFlowPipelineBuilder<TSource1, TSource2>

Namespace

DotnetKit.DataflowBuilder

Assembly

DotnetKit.DataflowBuilder.dll

Implements a multi-source dataflow pipeline builder joining two data streams with a JoinBlock<T1, T2>.

public class DataFlowPipelineBuilder<TSource1, TSource2> : DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>, IPipelineBuilder<TSource1, TSource2>, IPipelineBuilder<Tuple<TSource1, TSource2>>, IPipelineBuilder

Type Parameters

TSource1

The type of items in the first stream.

TSource2

The type of items in the second stream.

Inheritance

object

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>

DataFlowPipelineBuilder<TSource1, TSource2>

Implements

IPipelineBuilder<TSource1, TSource2>

IPipelineBuilder<Tuple<TSource1, TSource2>>

IPipelineBuilder

Inherited Members

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CancellationToken

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.Blocks

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.SourceBlock

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.AddPropagatorBlock<TInput, TOutput>(IPropagatorBlock<TInput, TOutput>)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.AddTargetBlock<TInput>(ITargetBlock<TInput>)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.Build()

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateBatchBlock<TInput>(int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateActionBlock<TInput>(Action<TInput>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateAsyncActionBlock<TInput>(Func<TInput, Task>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateAscynActionBlock<TInput>(Func<TInput, Task>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateTransformBlock<TInput, TOutput>(Func<TInput, TOutput>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateAsyncTransformBlock<TInput, TOutput>(Func<TInput, Task<TOutput>>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateTransformManyBlock<TInput, TOutput>(Func<TInput, IEnumerable<TOutput>>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.CreateAsyncTransformManyBlock<TInput, TOutput>(Func<TInput, Task<IEnumerable<TOutput>>>, int)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.HandleAsyncAction<TInput>(Func<TInput, Task>)

DataFlowPipelineBuilder<Tuple<TSource1, TSource2>>.HandleAsyncFunction<TInput, TOutput>(Func<TInput, Task<TOutput>>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DataFlowPipelineBuilder(ISourceBlock<TSource1>, ISourceBlock<TSource2>, CancellationToken)

Initializes a new instance of the DataFlowPipelineBuilder<TSource1, TSource2> class.

public DataFlowPipelineBuilder(ISourceBlock<TSource1> initialBlock1, ISourceBlock<TSource2> initialBlock2, CancellationToken cancellationToken)

Parameters

initialBlock1 ISourceBlock<TSource1>

The initial source block for the first stream.

initialBlock2 ISourceBlock<TSource2>

The initial source block for the second stream.

cancellationToken CancellationToken

A token to monitor for cancellation.

Properties

SourceBlock1

Gets the source block for the first input stream.

public ISourceBlock<TSource1> SourceBlock1 { get; }

Property Value

ISourceBlock<TSource1>

SourceBlock2

Gets the source block for the second input stream.

public ISourceBlock<TSource2> SourceBlock2 { get; }

Property Value

ISourceBlock<TSource2>

Methods

Build()

Builds the multi-source dataflow pipeline.

public IPipeline<TSource1, TSource2> Build()

Returns

IPipeline<TSource1, TSource2>

An executable IPipeline<TSource1, TSource2> instance.