Class WaitTransformation<TInput>
The WaitTransformation will wait for other components in the data flow before it continues to process data. Alternatively, the WaitTransformation can wait for one or more TaskCompletionSources before data can pass.
Inheritance
object
DataFlowSource<TInput>
DataFlowTransformation<TInput, TInput>
WaitTransformation<TInput>
Implements
IDataFlowTransformation<TInput, TInput>
IDataFlowSource<TInput>
IDataFlowDestination<TInput>
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public class WaitTransformation<TInput> : DataFlowTransformation<TInput, TInput>, ILoggableTask, IDataFlowLogging, IDataFlowTransformation<TInput, TInput>, IDataFlowSource<TInput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent
Type Parameters
Name | Description |
---|---|
TInput | The type of ingoing data. |
Constructors
WaitTransformation()
Declaration
public WaitTransformation()
WaitTransformation(params DataFlowComponent[])
Declaration
public WaitTransformation(params DataFlowComponent[] dataFlowComponents)
Parameters
Type | Name | Description |
---|---|---|
DataFlowComponent[] | dataFlowComponents |
WaitTransformation(params TaskCompletionSource<bool>[])
Declaration
public WaitTransformation(params TaskCompletionSource<bool>[] taskCompletionSources)
Parameters
Type | Name | Description |
---|---|---|
TaskCompletionSource<bool>[] | taskCompletionSources |
Properties
DataFlowComponents
Declaration
public DataFlowComponent[] DataFlowComponents { get; set; }
Property Value
Type | Description |
---|---|
DataFlowComponent[] |
SourceBlock
SourceBlock from the underlying TPL.Dataflow which is used as output buffer for the component.
Declaration
public override ISourceBlock<TInput> SourceBlock { get; }
Property Value
Type | Description |
---|---|
ISourceBlock<><TInput> |
Overrides
ETLBox.DataFlow.DataFlowSource<TInput>.SourceBlock
TargetBlock
TargetBlock from the underlying TPL.Dataflow which is used as input buffer for the component.
Declaration
public override ITargetBlock<TInput> TargetBlock { get; }
Property Value
Type | Description |
---|---|
ITargetBlock<><TInput> |
Overrides
ETLBox.DataFlow.DataFlowTransformation<TInput, TInput>.TargetBlock
TaskCompletionSources
Declaration
public TaskCompletionSource<bool>[] TaskCompletionSources { get; set; }
Property Value
Type | Description |
---|---|
TaskCompletionSource<bool>[] |
TaskName
A name to identify the task or component. Every component or task comes with a default name that can be overwritten.
Declaration
public override string TaskName { get; set; }
Property Value
Type | Description |
---|---|
string |
Overrides
Methods
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
Type | Name | Description |
---|---|---|
System.Exception | e |
Overrides
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()
Overrides
InitComponent()
Declaration
protected override void InitComponent()