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); 203int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, consumedMessageValue, null) : 1; 204_itemsRemovedAction(_owningSource, count); 314int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, item!, null) : 1; 315_itemsRemovedAction(_owningSource, count); 361int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, default(TOutput)!, items) : countReceived; 362_itemsRemovedAction(_owningSource, count); 646int count = _itemCountingFunc != null ? _itemCountingFunc(_owningSource, message!, null) : 1; 647_itemsRemovedAction(_owningSource, count); 671DataflowMessageStatus result = target.OfferMessage(header, message, _owningSource, consumeToAccept: false); 760_owningSource, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count); 843_completeAction(_owningSource); 972etwLog.DataflowBlockCompleted(_owningSource); 981var displaySource = _owningSource as IDebuggerDisplay; 982return $"Block = \"{(displaySource != null ? displaySource.Content : _owningSource)}\"";