3 writes to TaskForInputProcessing
System.Threading.Tasks.Dataflow (3)
Blocks\BatchBlock.cs (3)
463_nonGreedyState.TaskForInputProcessing = null; 641_nonGreedyState!.TaskForInputProcessing = new Task(static thisBatchTarget => ((BatchBlockTargetCore)thisBatchTarget!).ProcessMessagesLoopCore(), this, 711_nonGreedyState.TaskForInputProcessing = null;
7 references to TaskForInputProcessing
System.Threading.Tasks.Dataflow (7)
Blocks\BatchBlock.cs (7)
376(_boundingState.CountIsLessThanBound && _nonGreedyState!.PostponedMessages.Count == 0 && _nonGreedyState.TaskForInputProcessing == null))) 461Debug.Assert(_nonGreedyState != null && _nonGreedyState.TaskForInputProcessing != null, 507bool currentlyProcessing = _nonGreedyState != null && _nonGreedyState.TaskForInputProcessing != null; 569bool currentlyProcessing = _nonGreedyState != null && _nonGreedyState.TaskForInputProcessing != null; 648_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 653Exception? exception = Common.StartTaskSafe(_nonGreedyState.TaskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 1182public Task? TaskForInputProcessing { get { return _target._nonGreedyState?.TaskForInputProcessing; } }