3 writes to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (3)
Internal\SourceCore.cs (3)
753_taskForOutputProcessing = new Task(static thisSourceCore => ((SourceCore<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this, 771_taskForOutputProcessing = null; 854_taskForOutputProcessing = null;
13 references to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (13)
Internal\SourceCore.cs (13)
391if (_taskForOutputProcessing == null) 446if (_taskForOutputProcessing == null) 722if (_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty) 735Debug.Assert(_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty, 760_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 764Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 794Debug.Assert(_taskForOutputProcessing != null && _taskForOutputProcessing.Id == Task.CurrentId, 852Debug.Assert(_taskForOutputProcessing != null && _taskForOutputProcessing.Id == Task.CurrentId, 892_taskForOutputProcessing == null && // no current processing 907_decliningPermanently && _taskForOutputProcessing == null && _nextMessageReservedFor == null, 1005internal Task? TaskForOutputProcessing { get { return _source._taskForOutputProcessing; } }