ETLBox
Title here
Summary here
WaitTransformation<TInput>
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.
Implements
IDataFlowTransformation<TInput, TInput>
IDataFlowSource<TInput>
IDataFlowDestination<TInput>
Inherited Members
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
public class WaitTransformation<TInput> : DataFlowTransformation<TInput, TInput>, IDataFlowTransformation<TInput, TInput>, IDataFlowSource<TInput>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTaskType 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
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
TaskCompletionSources
Declaration
public TaskCompletionSource<bool>[] TaskCompletionSources { get; set; }Property Value
| Type | Description |
|---|---|
| TaskCompletionSource<bool>[] |
Methods
CheckParameter()
Declaration
protected override void CheckParameter()Overrides
CleanUpOnFaulted(Exception)
Declaration
protected override void CleanUpOnFaulted(Exception e)Parameters
| Type | Name | Description |
|---|---|---|
| Exception | e |
Overrides
CleanUpOnSuccess()
Declaration
protected override void CleanUpOnSuccess()Overrides
InitComponent()
Declaration
protected override void InitComponent()Overrides
Reset()
Declaration
protected override void Reset()