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