Class DataFlowDestination<TInput>

Inheritance
System.Object
GenericTask
DataFlowTask
DataFlowDestination<TInput>
CustomDestination<TInput>
MemoryDestination<TInput>
DataFlowBatchDestination<TInput>
DataFlowStreamDestination<TInput>
Implements
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public abstract class DataFlowDestination<TInput> : DataFlowTask, IDataFlowDestination<TInput>, IDataFlowLinkTarget<TInput>, ITask
Type Parameters
Name Description
TInput

Properties

Completion

Declaration
public Task Completion { get; protected set; }
Property Value
Type Description
System.Threading.Tasks.Task

ErrorHandler

Declaration
public ErrorHandler ErrorHandler { get; set; }
Property Value
Type Description
ErrorHandler

OnCompletion

Declaration
public Action OnCompletion { get; set; }
Property Value
Type Description
System.Action

PredecessorCompletions

Declaration
protected List<Task> PredecessorCompletions { get; set; }
Property Value
Type Description
System.Collections.Generic.List<System.Threading.Tasks.Task>

TargetAction

Declaration
protected ActionBlock<TInput> TargetAction { get; set; }
Property Value
Type Description
System.Threading.Tasks.Dataflow.ActionBlock<TInput>

TargetBlock

Declaration
public ITargetBlock<TInput> TargetBlock { get; }
Property Value
Type Description
System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

Methods

AddPredecessorCompletion(Task)

Declaration
public void AddPredecessorCompletion(Task completion)
Parameters
Type Name Description
System.Threading.Tasks.Task completion

AwaitCompletion()

Declaration
protected virtual Task AwaitCompletion()
Returns
Type Description
System.Threading.Tasks.Task

CheckCompleteAction()

Declaration
protected void CheckCompleteAction()

CleanUp()

Declaration
protected virtual void CleanUp()

LinkErrorTo(IDataFlowLinkTarget<ETLBoxError>)

Declaration
public void LinkErrorTo(IDataFlowLinkTarget<ETLBoxError> target)
Parameters
Type Name Description
IDataFlowLinkTarget<ETLBoxError> target

SetCompletionTask()

Declaration
protected void SetCompletionTask()

Wait()

Declaration
public virtual void Wait()

Implements