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
WaitTransformation<TInput>
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
public class WaitTransformation<TInput> : DataFlowTransformation<TInput, TInput>, IDataFlowLogging, IDataFlowTransformation<TInput, TInput>, IDataFlowSource<TInput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
| Name | Description |
|---|
| TInput | The type of ingoing data. |
Constructors
Declaration
public WaitTransformation()
Declaration
public WaitTransformation(params DataFlowComponent[] dataFlowComponents)
Parameters
Declaration
public WaitTransformation(params TaskCompletionSource<bool>[] taskCompletionSources)
Parameters
Properties
Declaration
public DataFlowComponent[] DataFlowComponents { get; set; }
Property Value
SourceBlock from the underlying TPL.Dataflow which is used as output buffer for the component.
Declaration
public override ISourceBlock<TInput> SourceBlock { get; }
Property Value
Overrides
TargetBlock from the underlying TPL.Dataflow which is used as input buffer for the component.
Declaration
public override ITargetBlock<TInput> TargetBlock { get; }
Property Value
Overrides
Declaration
public TaskCompletionSource<bool>[] TaskCompletionSources { get; set; }
Property Value
Methods
Declaration
protected override void CheckParameter()
Overrides
Declaration
protected override void CleanUpOnFaulted(Exception e)
Parameters
Overrides
Declaration
protected override void CleanUpOnSuccess()
Overrides
Declaration
protected override void InitComponent()
Overrides
Declaration
protected override void Reset()
Overrides
Implements