6 writes to TaskForInputProcessing
System.Threading.Tasks.Dataflow (6)
Blocks\BroadcastBlock.cs (3)
138_boundingState.TaskForInputProcessing = null; 253_boundingState.TaskForInputProcessing = 303_boundingState.TaskForInputProcessing = null;
Blocks\BufferBlock.cs (3)
173_boundingState.TaskForInputProcessing = null; 254_boundingState.TaskForInputProcessing = 305_boundingState.TaskForInputProcessing = null;
21 references to TaskForInputProcessing
System.Threading.Tasks.Dataflow (21)
Blocks\BroadcastBlock.cs (10)
136Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 183(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 247_boundingState.TaskForInputProcessing == null && 261this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 266Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 279Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 281Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 325Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 327Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 374(_boundingState == null || _boundingState.TaskForInputProcessing == null))
Blocks\BufferBlock.cs (11)
111(_boundingState.CountIsLessThanBound && _boundingState.PostponedMessages.Count == 0 && _boundingState.TaskForInputProcessing == null)) 171Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 248_boundingState.TaskForInputProcessing == null && 262this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 267Exception? exception = Common.StartTaskSafe(_boundingState.TaskForInputProcessing, _source.DataflowBlockOptions.TaskScheduler); 281Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 283Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 327Debug.Assert(_boundingState != null && _boundingState.TaskForInputProcessing != null, 329Debug.Assert(_boundingState.TaskForInputProcessing.Id == Task.CurrentId, 377(_boundingState == null || _boundingState.TaskForInputProcessing == null)) 456public Task? TaskForInputProcessing { get { return _bufferBlock._boundingState?.TaskForInputProcessing; } }