Title here
Summary here
Define your own destination block. This block accepts all data from the flow and sends each incoming row to your custom Action, along with a count of processed rows.
public class CustomDestination : CustomDestination<ExpandoObject>, IDataFlowDestination<ExpandoObject>, IDataFlowDestination, IDataFlowComponent, ILoggableTaskList<MyRow> rows = new List<MyRow>();
var dest = new CustomDestination<MyRow>();
dest.WriteAction = (row, progressCount) => rows.Add(row); public CustomDestination() public CustomDestination(Action<ExpandoObject, int> writeAction)| Type | Name | Description |
|---|---|---|
| Action<ExpandoObject, int> | writeAction | Sets the WriteAction |