3 writes to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (3)
Internal\SourceCore.cs (3)
759_taskForOutputProcessing = new Task(static thisSourceCore => ((SourceCore<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this, 777_taskForOutputProcessing = null; 860_taskForOutputProcessing = null;
13 references to _taskForOutputProcessing
System.Threading.Tasks.Dataflow (13)
Internal\SourceCore.cs (13)
397if (_taskForOutputProcessing == null) 452if (_taskForOutputProcessing == null) 728if (_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty) 741Debug.Assert(_taskForOutputProcessing == null && _enableOffering && !_messages.IsEmpty, 766_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 770Exception? exception = Common.StartTaskSafe(_taskForOutputProcessing, _dataflowBlockOptions.TaskScheduler); 800Debug.Assert(_taskForOutputProcessing != null && _taskForOutputProcessing.Id == Task.CurrentId, 858Debug.Assert(_taskForOutputProcessing != null && _taskForOutputProcessing.Id == Task.CurrentId, 898_taskForOutputProcessing == null && // no current processing 913_decliningPermanently && _taskForOutputProcessing == null && _nextMessageReservedFor == null, 1011internal Task? TaskForOutputProcessing { get { return _source._taskForOutputProcessing; } }