1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
559_dataflowBlockOptions = dataflowBlockOptions;
7 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (7)
Blocks\BroadcastBlock.cs (7)
848Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 880int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 989else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 991_completionTask.TrySetCanceled(_dataflowBlockOptions.CancellationToken); 1153return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || 1189internal DataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 1225public DataflowBlockOptions DataflowBlockOptions { get { return _source._dataflowBlockOptions; } }