Class RowsActionTarget<TInput>
A dataflow worker with one Input that repeatedly executes a callback when there are rows
to consume from the upstream worker.
Note: Use the factory methods in RowsActionTargetFactory to create instances of this class.
Also see the RowsActionTarget example.
Note: The input port uses the Default policy. Consider whether this is appropriate, or should be changed, see BufferingMode for further details.
Implements
Inherited Members
Namespace: actionETL
Assembly: actionETL.dll
Syntax
public class RowsActionTarget<TInput> : WorkerBase<RowsActionTarget<TInput>>, IDisposeOnFinished where TInput : classType Parameters
| Name | Description |
|---|---|
| TInput | The type of each |
Properties
Input
Gets the input port for receiving rows from an upstream worker.
Declaration
public InputPort<TInput> Input { get; }Property Value
| Type | Description |
|---|---|
| InputPort<TInput> |
Methods
RunAsync()
This method can be overridden to add custom functionality to the derived worker that runs before
and after the row processing, but after
AddStartingCallback(Func<WorkerBase, Task<ProgressStatus>>) and before
AddRanCallback(Func<WorkerBase, OutcomeStatus, WorkerParentChildrenState, Task<OutcomeStatus>>).
In this case, the base class base.RunAsync()
must be called for the worker to function correctly.
Typically, this worker is used without overriding this method.
Declaration
protected override async Task<OutcomeStatus> RunAsync()Returns
| Type | Description |
|---|---|
| Task<OutcomeStatus> | A |