3 writes to TaskForInputProcessing
System.Threading.Tasks.Dataflow (3)
Blocks\BatchBlock.cs (3)
460_nonGreedyState.TaskForInputProcessing = null; 638_nonGreedyState!.TaskForInputProcessing = new Task(static thisBatchTarget => ((BatchBlockTargetCore)thisBatchTarget!).ProcessMessagesLoopCore(), this, 708_nonGreedyState.TaskForInputProcessing = null;
7 references to TaskForInputProcessing
System.Threading.Tasks.Dataflow (7)
Blocks\BatchBlock.cs (7)
373(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 458Debug.Assert(_nonGreedyState != null && _nonGreedyState.TaskForInputProcessing != null, 504bool currentlyProcessing = _nonGreedyState != null && _nonGreedyState.TaskForInputProcessing != null; 566bool currentlyProcessing = _nonGreedyState != null && _nonGreedyState.TaskForInputProcessing != null; 645_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 650Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1179public Task? TaskForInputProcessing { get { return _target._nonGreedyState?.TaskForInputProcessing; } }