1 instantiation of SpscTargetCore
System.Threading.Tasks.Dataflow (1)
Blocks\ActionBlock.cs (1)
96
_spscTarget = new
SpscTargetCore
<TInput>(this, syncAction, dataflowBlockOptions);
5 references to SpscTargetCore
System.Threading.Tasks.Dataflow (5)
Blocks\ActionBlock.cs (2)
30
private readonly
SpscTargetCore
<TInput>? _spscTarget;
330
private readonly
SpscTargetCore
<TInput>.DebuggingInformation? _spscDebugInfo;
Internal\SpscTargetCore.cs (3)
167
static state => ((
SpscTargetCore
<TInput>)state!).ProcessMessagesLoopCore(),
384
private readonly
SpscTargetCore
<TInput> _target;
388
internal DebuggingInformation(
SpscTargetCore
<TInput> target) { _target = target; }