1 instantiation of BroadcastingSourceCore
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
82
_source = new
BroadcastingSourceCore
<T>(this, cloningFunction, dataflowBlockOptions, onItemsRemoved);
10 references to BroadcastingSourceCore
System.Threading.Tasks.Dataflow (10)
Blocks\BroadcastBlock.cs (10)
39
private readonly
BroadcastingSourceCore
<T> _source;
452
private readonly
BroadcastingSourceCore
<T>.DebuggingInformation _sourceDebuggingInformation;
642
var
thisSourceCore = (
BroadcastingSourceCore
<TOutput>)state!;
831
_taskForOutputProcessing = new Task(static thisSourceCore => ((
BroadcastingSourceCore
<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this,
856
var
thisSourceCore = (
BroadcastingSourceCore
<TOutput>)state!;
946
Task.Factory.StartNew(static thisSourceCore => ((
BroadcastingSourceCore
<TOutput>)thisSourceCore!).CompleteBlockOncePossible(),
1197
private readonly
BroadcastingSourceCore
<TOutput> _source;
1201
public DebuggingInformation(
BroadcastingSourceCore
<TOutput> source) { _source = source; }