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)
211messageValue = source.ConsumeMessage(messageHeader, _owningTarget, out consumed)!; 379_owningTarget, taskForInputProcessing, DataflowEtwProvider.TaskLaunchedReason.ProcessingInputMessages, 671TInput? consumedValue = element.Key.ConsumeMessage(element.Value, _owningTarget, out consumed); 765Common.ReleaseAllPostponedMessages(_owningTarget, _boundingState.PostponedMessages, ref _exceptions); 800etwLog.DataflowBlockCompleted(_owningTarget); 831var displayTarget = _owningTarget as IDebuggerDisplay; 832return $"Block = \"{(displayTarget != null ? displayTarget.Content : _owningTarget)}\"";