7 references to ProcessingInputMessages
System.Threading.Tasks.Dataflow (7)
Blocks\BatchBlock.cs (1)
648
_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Blocks\BroadcastBlock.cs (1)
267
this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Blocks\BufferBlock.cs (1)
268
this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Blocks\JoinBlock.cs (1)
1289
_ownerJoin, _taskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Internal\DataflowEtwProvider.cs (1)
96
Debug.Assert(reason == TaskLaunchedReason.
ProcessingInputMessages
|| reason == TaskLaunchedReason.OfferingOutputMessages,
Internal\SpscTargetCore.cs (1)
177
_owningTarget, newConsumer, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
, _messages.Count);
Internal\TargetCore.cs (1)
379
_owningTarget, taskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,