Interface IPipelineBuilder<TSource1, TSource2>

Namespace

DotnetKit.DataflowBuilder

Assembly

DotnetKit.DataflowBuilder.dll

Defines a multi-source pipeline builder that joins two inputs (TSource1 and TSource2).

public interface IPipelineBuilder<TSource1, TSource2> : IPipelineBuilder<Tuple<TSource1, TSource2>>, IPipelineBuilder

Type Parameters

TSource1

The type of the first source.

TSource2

The type of the second source.

Inherited Members

IPipelineBuilder<Tuple<TSource1, TSource2>>.SourceBlock

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

IPipelineBuilder.CancellationToken

IPipelineBuilder.AddPropagatorBlock<TInput, TOutput>(IPropagatorBlock<TInput, TOutput>)

IPipelineBuilder.AddTargetBlock<TInput>(ITargetBlock<TInput>)

IPipelineBuilder.CreateAsyncTransformBlock<TInput, TOutput>(Func<TInput, Task<TOutput>>, int)

IPipelineBuilder.CreateActionBlock<TInput>(Action<TInput>, int)

IPipelineBuilder.CreateAsyncActionBlock<TInput>(Func<TInput, Task>, int)

IPipelineBuilder.CreateAscynActionBlock<TInput>(Func<TInput, Task>, int)

IPipelineBuilder.CreateTransformBlock<TInput, TOutput>(Func<TInput, TOutput>, int)

IPipelineBuilder.CreateTransformManyBlock<TInput, TOutput>(Func<TInput, IEnumerable<TOutput>>, int)

IPipelineBuilder.CreateAsyncTransformManyBlock<TInput, TOutput>(Func<TInput, Task<IEnumerable<TOutput>>>, int)

IPipelineBuilder.CreateBatchBlock<TInput>(int)

Properties

SourceBlock1

Gets the source block for the first input stream.

ISourceBlock<TSource1> SourceBlock1 { get; }

Property Value

ISourceBlock<TSource1>

SourceBlock2

Gets the source block for the second input stream.

ISourceBlock<TSource2> SourceBlock2 { get; }

Property Value

ISourceBlock<TSource2>

Methods

Build()

Builds the multi-source dataflow pipeline.

IPipeline<TSource1, TSource2> Build()

Returns

IPipeline<TSource1, TSource2>

An executable IPipeline<TSource1, TSource2> instance.