1 write to _spscTarget
System.Threading.Tasks.Dataflow (1)
Blocks\ActionBlock.cs (1)
90_spscTarget = new SpscTargetCore<TInput>(this, syncAction, dataflowBlockOptions);
13 references to _spscTarget
System.Threading.Tasks.Dataflow (13)
Blocks\ActionBlock.cs (13)
122Debug.Assert((_spscTarget != null) ^ (_defaultTarget != null), "One and only one of the two targets must be non-null after construction"); 226Debug.Assert(_spscTarget != null); 227_spscTarget.Complete(exception: null); 242Debug.Assert(_spscTarget != null); 243_spscTarget.Complete(exception); 250get { return _defaultTarget != null ? _defaultTarget.Completion : _spscTarget!.Completion; } 277_spscTarget!.Post(item); 285_spscTarget!.OfferMessage(messageHeader, messageValue, source, consumeToAccept); 291get { return _defaultTarget != null ? _defaultTarget.InputCount : _spscTarget!.InputCount; } 297get { return _defaultTarget != null ? _defaultTarget.GetDebuggingInformation().InputCount : _spscTarget!.InputCount; } 303return Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions); 308$"{(Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions))}, InputCount = {InputCountForDebugger}"; 335_spscDebugInfo = actionBlock._spscTarget!.GetDebuggingInformation();