1 write to _owningSource
System.Threading.Tasks.Dataflow (1)
Internal\SourceCore.cs (1)
113_owningSource = owningSource;
15 references to _owningSource
System.Threading.Tasks.Dataflow (15)
Internal\SourceCore.cs (15)
120_targetRegistry = new TargetRegistry<TOutput>(_owningSource); 209int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, consumedMessageValue, null) : 1; 210_itemsRemovedAction(_owningSource, count); 320int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, item!, null) : 1; 321_itemsRemovedAction(_owningSource, count); 367int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, default(TOutput)!, items) : countReceived; 368_itemsRemovedAction(_owningSource, count); 652int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, message!, null) : 1; 653_itemsRemovedAction(_owningSource, count); 677DataflowMessageStatus result = target.OfferMessage(header, message, _owningSource, consumeToAccept: false); 766_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 849_completeAction(_owningSource); 978etwLog.DataflowBlockCompleted(_owningSource); 987var displaySource = _owningSource as IDebuggerDisplay; 988return $"Block = \"{(displaySource != null ? displaySource.Content : _owningSource)}\"";