3 writes to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (3)
Blocks\BroadcastBlock.cs (3)
831_taskForOutputProcessing = new Task(static thisSourceCore => ((BroadcastingSourceCore<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this, 850_taskForOutputProcessing = null; 897_taskForOutputProcessing = null;
6 references to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (6)
Blocks\BroadcastBlock.cs (6)
823bool currentlyProcessing = _taskForOutputProcessing != null; 838_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 842Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 920bool currentlyProcessing = _taskForOutputProcessing != null; 938Debug.Assert(_taskForOutputProcessing == null, "There must be no processing tasks."); 1210public Task? TaskForOutputProcessing { get { return _source._taskForOutputProcessing; } }