Interface IPipelineDestination<T>

Namespace

Pipelinez.Core.Destination

Assembly

Pipelinez.dll

Defines a pipeline destination that consumes terminal pipeline containers.

public interface IPipelineDestination<T> : IFlowDestination<PipelineContainer<T>> where T : PipelineRecord

Type Parameters

T

The pipeline record type written by the destination.

Inherited Members

IFlowDestination<PipelineContainer<T>>.AsTargetBlock()

Properties

Completion

Gets a task that completes when the destination has fully finished processing.

Task Completion { get; }

Property Value

Task

Methods

Initialize(Pipeline<T>)

Initializes the destination with its parent pipeline.

void Initialize(Pipeline<T> parentPipeline)

Parameters

parentPipeline Pipeline<T>

The owning pipeline.

StartAsync(CancellationTokenSource)

Starts the destination execution loop.

Task StartAsync(CancellationTokenSource cancellationToken)

Parameters

cancellationToken CancellationTokenSource

The runtime cancellation source used to stop the destination.

Returns

Task