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()