1 write to _spscTarget
System.Threading.Tasks.Dataflow (1)
Blocks\ActionBlock.cs (1)
96_spscTarget = new SpscTargetCore<TInput>(this, syncAction, dataflowBlockOptions);
13 references to _spscTarget
System.Threading.Tasks.Dataflow (13)
Blocks\ActionBlock.cs (13)
128Debug.Assert((_spscTarget != null) ^ (_defaultTarget != null), "One and only one of the two targets must be non-null after construction"); 232Debug.Assert(_spscTarget != null); 233_spscTarget.Complete(exception: null); 251Debug.Assert(_spscTarget != null); 252_spscTarget.Complete(exception); 259get { return _defaultTarget != null ? _defaultTarget.Completion : _spscTarget!.Completion; } 286_spscTarget!.Post(item); 294_spscTarget!.OfferMessage(messageHeader, messageValue, source, consumeToAccept); 300get { return _defaultTarget != null ? _defaultTarget.InputCount : _spscTarget!.InputCount; } 306get { return _defaultTarget != null ? _defaultTarget.GetDebuggingInformation().InputCount : _spscTarget!.InputCount; } 312return Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions); 317$"{(Common.GetNameForDebugger(this, _defaultTarget != null ? _defaultTarget.DataflowBlockOptions : _spscTarget!.DataflowBlockOptions))}, InputCount = {InputCountForDebugger}"; 344_spscDebugInfo = actionBlock._spscTarget!.GetDebuggingInformation();