1 instantiation of BroadcastingSourceCore
System.Threading.Tasks.Dataflow (1)
Blocks\BroadcastBlock.cs (1)
85
_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;
458
private readonly
BroadcastingSourceCore
<T>.DebuggingInformation _sourceDebuggingInformation;
648
var
thisSourceCore = (
BroadcastingSourceCore
<TOutput>)state!;
837
_taskForOutputProcessing = new Task(static thisSourceCore => ((
BroadcastingSourceCore
<TOutput>)thisSourceCore!).OfferMessagesLoopCore(), this,
862
var
thisSourceCore = (
BroadcastingSourceCore
<TOutput>)state!;
952
Task.Factory.StartNew(static thisSourceCore => ((
BroadcastingSourceCore
<TOutput>)thisSourceCore!).CompleteBlockOncePossible(),
1209
private readonly
BroadcastingSourceCore
<TOutput> _source;
1213
public DebuggingInformation(
BroadcastingSourceCore
<TOutput> source) { _source = source; }