1 write to PropagateCompletion
System.Threading.Tasks.Dataflow (1)
Base\DataflowLinkOptions.cs (1)
72internal static readonly DataflowLinkOptions UnlinkAfterOneAndPropagateCompletion = new DataflowLinkOptions() { MaxMessages = 1, PropagateCompletion = true };
5 references to PropagateCompletion
System.Threading.Tasks.Dataflow (5)
Blocks\BroadcastBlock.cs (1)
1028if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(_completionTask.Task, target);
Blocks\WriteOnceBlock.cs (1)
338if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(Completion, target);
Internal\SourceCore.cs (2)
140if (linkOptions.PropagateCompletion) Common.PropagateCompletion(_completionTask.Task, target, exceptionHandler: null); 158if (linkOptions.PropagateCompletion) Common.PropagateCompletionOnceCompleted(_completionTask.Task, target);
Internal\TargetRegistry.cs (1)
41PropagateCompletion = linkOptions.PropagateCompletion;