1 write to _owningSource
System.Threading.Tasks.Dataflow (1)
Internal\TargetRegistry.cs (1)
316
_owningSource
= owningSource;
7 references to _owningSource
System.Threading.Tasks.Dataflow (7)
Internal\TargetRegistry.cs (7)
323
Debug.Assert(source ==
_owningSource
, "Only valid to be used with the source for which it was created.");
330
return
_owningSource
.ConsumeMessage(messageHeader, this, out messageConsumed);
336
return
_owningSource
.ReserveMessage(messageHeader, this);
342
_owningSource
.ReleaseReservation(messageHeader, this);
346
Task IDataflowBlock.Completion { get { return
_owningSource
.Completion; } }
360
var displaySource =
_owningSource
as IDebuggerDisplay;
362
return $"{Common.GetNameForDebugger(this)} Source = \"{(displaySource != null ? displaySource.Content :
_owningSource
)}\", Target = \"{(displayTarget != null ? displayTarget.Content : _target)}\"";