Class CustomSource<TOutput>

Namespace: ETLBox.DataFlow

Assembly: ETLBox.dll

Syntax#

    public class CustomSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask

Type Parameters

Examples#

 List<string> Data = new List<string>()
 {
     "Test1", "Test2", "Test3"
 };
 var source = new CustomSource<MyRow>();
 source.ReadFunc = progressCount =>
 {
     return new MyRow()
     {
         Id = progressCount + 1,
         Value = Data[progressCount]
     };    
    return result;
 };
source.ReadCompletedFunc =  progressCount => progressCount >= Data.Count;

Constructors

CustomSource()#

Declaration

    public CustomSource()

CustomSource(Func<int, TOutput>, Predicate<int>)#

Declaration

    public CustomSource(Func<int, TOutput> readFunc, Predicate<int> readingCompleted)

Parameters

Properties

ReadFunc#

Declaration

    public Func<int, TOutput> ReadFunc { get; set; }

Property Value

ReadingCompleted#

Declaration

    public Predicate<int> ReadingCompleted { get; set; }

Property Value

Methods

CheckParameter()#

Declaration

    protected override void CheckParameter()

Overrides

CleanUpOnFaulted(Exception)#

Declaration

    protected override void CleanUpOnFaulted(Exception e)

Parameters

Overrides

CleanUpOnSuccess()#

Declaration

    protected override void CleanUpOnSuccess()

Overrides

OnExecutionDoAsyncWork()#

Declaration

    protected override void OnExecutionDoAsyncWork()

Overrides

Implements#