Interface IPipelineWithLoadProgress<TProgress>

Namespace

Wolfgang.Etl.Abstractions

Assembly

Wolfgang.Etl.Abstractions.dll

An IPipeline whose loader supports progress reporting. Call WithProgress(IProgress<TProgress>) to supply an IProgress<T> sink that will be forwarded to the loader's LoadAsync overload when the pipeline runs.

public interface IPipelineWithLoadProgress<out TProgress> : IPipeline where TProgress : notnull

Type Parameters

TProgress

The type of progress report emitted by the loader.

Inherited Members

IPipeline.WithName(string)

IPipeline.Name

IPipeline.RunAsync()

IPipeline.RunAsync(CancellationToken)

Methods

WithProgress(IProgress<TProgress>)

Supplies an IProgress<T> sink that the pipeline will pass to the loader's LoadAsync overload when the pipeline runs. The returned pipeline is a plain IPipeline — progress can only be set once.

IPipeline WithProgress(IProgress<out TProgress> progress)

Parameters

progress IProgress<TProgress>

The progress sink to forward reports to.

Returns

IPipeline

The same pipeline, typed as IPipeline.

Exceptions

ArgumentNullException

progress is null.