Interface IPipelineBuilder<TSource>

Namespace

DotnetKit.DataflowBuilder.Abstractions

Assembly

DotnetKit.DataflowBuilder.dll

Defines a typed pipeline builder for pipelines initiated from an input source of type TSource.

public interface IPipelineBuilder<TSource> : IPipelineBuilder

Type Parameters

TSource

The initial data item type accepted by the pipeline.

Inherited Members

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

SourceBlock

Gets the initial source block of the pipeline.

ISourceBlock<TSource> SourceBlock { get; }

Property Value

ISourceBlock<TSource>

Methods

Build()

Builds and encapsulates the configured dataflow blocks into an executable IPipeline<TSource>.

IPipeline<TSource> Build()

Returns

IPipeline<TSource>

An executable dataflow pipeline instance.