Interface IExtractStageWithProgress<TSource, TProgress>

Namespace

Wolfgang.Etl.Abstractions

Assembly

Wolfgang.Etl.Abstractions.dll

An IExtractStage<TSource> whose underlying extractor also supports progress reporting. Call WithProgress(IProgress<TProgress>) to supply an IProgress<T> sink that will be forwarded to the extractor's ExtractAsync overload when the pipeline runs.

public interface IExtractStageWithProgress<TSource, out TProgress> : IExtractStage<TSource> where TSource : notnull where TProgress : notnull

Type Parameters

TSource

The type of item produced by the extractor.

TProgress

The type of progress report emitted by the extractor.

Inherited Members

IExtractStage<TSource>.Transform<TDestination>(ITransformAsync<TSource, TDestination>)

IExtractStage<TSource>.Transform<TDestination>(ITransformWithCancellationAsync<TSource, TDestination>)

IExtractStage<TSource>.Transform<TDestination, TProgress>(ITransformWithProgressAsync<TSource, TDestination, TProgress>)

IExtractStage<TSource>.Transform<TDestination, TProgress>(ITransformWithProgressAndCancellationAsync<TSource, TDestination, TProgress>)

IExtractStage<TSource>.Load(ILoadAsync<TSource>)

IExtractStage<TSource>.Load(ILoadWithCancellationAsync<TSource>)

IExtractStage<TSource>.Load<TProgress>(ILoadWithProgressAsync<TSource, TProgress>)

IExtractStage<TSource>.Load<TProgress>(ILoadWithProgressAndCancellationAsync<TSource, TProgress>)

Methods

WithProgress(IProgress<TProgress>)

Supplies an IProgress<T> sink that the pipeline will pass to the extractor's ExtractAsync overload when the pipeline runs. The returned stage is a plain IExtractStage<TSource> — progress can only be set once.

IExtractStage<TSource> WithProgress(IProgress<out TProgress> progress)

Parameters

progress IProgress<TProgress>

The progress sink to forward reports to.

Returns

IExtractStage<TSource>

The same stage, typed as IExtractStage<TSource>.

Exceptions

ArgumentNullException

progress is null.