Class ActionTarget<TInput, TError>

A dataflow worker which executes an asynchronous callback once, which in turn calls methods on the Input port to consume rows from the upstream worker.

The target also has an ErrorOutput port.

Note: Use the factory methods in ActionTargetFactory to create instances of this class.

Also see the ActionTarget example.

Note: The input port uses the Default policy. Consider whether this is appropriate, or should be changed, see BufferingMode for further details.

Note: This class only has overloads for asynchronous callbacks, since using synchronous ones would require the callback to block a thread when there are no upstream rows available, which is not appropriate.

Inheritance
Object
WorkerParent
WorkerBase
WorkerBase<ActionTarget<TInput, TError>>
ActionWorkerBase<ActionTarget<TInput, TError>>
ActionTarget<TInput, TError>
Implements
Inherited Members
Namespace: actionETL
Assembly: actionETL.dll
Syntax
public class ActionTarget<TInput, TError> : ActionWorkerBase<ActionTarget<TInput, TError>>, IDisposeOnFinished where TInput : class where TError : class
Type Parameters
Name Description
TInput

The type of each Input row.
TError

The type of each ErrorOutput row.

Properties

ErrorOutput

Gets the error output port for sending error rows to logging and an optional downstream worker.

Declaration
public ErrorOutputPort<TError> ErrorOutput { get; }
Property Value
Type Description
ErrorOutputPort<TError>

Input

Gets the input port for receiving rows from an upstream worker.

Declaration
public InputPort<TInput> Input { get; }
Property Value
Type Description
InputPort<TInput>

Implements

See Also

ActionTarget<TInput>