Implemented interface member:
property
Completion
System.Threading.Tasks.Dataflow.IDataflowBlock.Completion
5 references to Completion
System.Threading.Tasks.Dataflow (5)
Base\DataflowBlock.cs (4)
2237
_observersState.Target.
Completion
.IsCompleted)
2384
Target.
Completion
.ContinueWith(
2397
ti.Target.
Completion
.ContinueWith(
2470
Debug.Assert(Target.
Completion
.IsCompleted, "The target must have already completed in order to notify of completion.");
Blocks\ActionBlock.cs (1)
114
dataflowBlockOptions.CancellationToken,
Completion
, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _defaultTarget);