1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
553_dataflowBlockOptions = dataflowBlockOptions;
7 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (7)
Blocks\BroadcastBlock.cs (7)
842Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 874int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 983else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 985_completionTask.TrySetCanceled(_dataflowBlockOptions.CancellationToken); 1141return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || 1177internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 1213public DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } }