1 write to _owningSource
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
551
_owningSource
= owningSource;
8 references to _owningSource
System.Threading.Tasks.Dataflow (8)
Blocks\BroadcastBlock.cs (8)
557
_targetRegistry = new TargetRegistry<TOutput>(
_owningSource
);
687
DataflowMessageStatus result = target.OfferMessage(new DataflowMessageHeader(_nextMessageId), currentMessage!,
_owningSource
, consumeToAccept: useCloning);
792
switch (target.OfferMessage(header, message,
_owningSource
, consumeToAccept: useCloning))
838
_owningSource
, _taskForOutputProcessing, DataflowEtwProvider.TaskLaunchedReason.OfferingOutputMessages, _messages.Count);
888
_owningSource
.CompleteCore(exception, storeExceptionEvenIfAlreadyCompleting: true);
998
etwLog.DataflowBlockCompleted(
_owningSource
);
1184
var displaySource =
_owningSource
as IDebuggerDisplay;
1185
return $"Block = \"{(displaySource != null ? displaySource.Content :
_owningSource
)}\"";