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