3 writes to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (3)
Blocks\BroadcastBlock.cs (3)
837_taskForOutputProcessing = new Task(static thisSourceCore => ((BroadcastingSourceCore<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this, 856_taskForOutputProcessing = null; 903_taskForOutputProcessing = null;
6 references to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (6)
Blocks\BroadcastBlock.cs (6)
829bool currentlyProcessing = _taskForOutputProcessing != null; 844_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 848Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 926bool currentlyProcessing = _taskForOutputProcessing != null; 944Debug.Assert(_taskForOutputProcessing == null, "There must be no processing tasks."); 1222public Task? TaskForOutputProcessing { get { return _source._taskForOutputProcessing; } }