1 write to _owningTarget
System.Threading.Tasks.Dataflow (1)
Internal\TargetCore.cs (1)
119
_owningTarget
= owningTarget;
7 references to _owningTarget
System.Threading.Tasks.Dataflow (7)
Internal\TargetCore.cs (7)
211
messageValue = source.ConsumeMessage(messageHeader,
_owningTarget
, out consumed)!;
379
_owningTarget
, taskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages,
671
TInput? consumedValue = element.Key.ConsumeMessage(element.Value,
_owningTarget
, out consumed);
765
Common.ReleaseAllPostponedMessages(
_owningTarget
, _boundingState.PostponedMessages, ref _exceptions);
800
etwLog.DataflowBlockCompleted(
_owningTarget
);
831
var displayTarget =
_owningTarget
as IDebuggerDisplay;
832
return $"Block = \"{(displayTarget != null ? displayTarget.Content :
_owningTarget
)}\"";