6 writes to TaskForInputProcessing
System.Threading.Tasks.Dataflow (6)
Blocks\BroadcastBlock.cs (3)
144_boundingState.TaskForInputProcessing = null; 259_boundingState.TaskForInputProcessing = 309_boundingState.TaskForInputProcessing = null;
Blocks\BufferBlock.cs (3)
179_boundingState.TaskForInputProcessing = null; 260_boundingState.TaskForInputProcessing = 311_boundingState.TaskForInputProcessing = null;
21 references to TaskForInputProcessing
System.Threading.Tasks.Dataflow (21)
Blocks\BroadcastBlock.cs (10)
142Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 189(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 253_boundingState.TaskForInputProcessing == null && 267this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 272Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 285Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 287Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 331Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 333Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 380(_boundingState == null || _boundingState.TaskForInputProcessing == null))
Blocks\BufferBlock.cs (11)
114(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 177Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 254_boundingState.TaskForInputProcessing == null && 268this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 273Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 287Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 289Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 333Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 335Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 383(_boundingState == null || _boundingState.TaskForInputProcessing == null)) 462public Task? TaskForInputProcessing { get { return _bufferBlock._boundingState?.TaskForInputProcessing; } }