7 references to ProcessingInputMessages
System.Threading.Tasks.Dataflow (7)
Blocks\BatchBlock.cs (1)
645
_owningBatch, _nonGreedyState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Blocks\BroadcastBlock.cs (1)
261
this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Blocks\BufferBlock.cs (1)
262
this, _boundingState.TaskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.
ProcessingInputMessages
,
Blocks\JoinBlock.cs (1)
1274
_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
,