2 writes to _defaultTarget
System.Threading.Tasks.Dataflow (2)
Blocks\ActionBlock.cs (2)
105_defaultTarget = new TargetCore<TInput>(this, 113_defaultTarget = new TargetCore<TInput>(this,
31 references to _defaultTarget
System.Threading.Tasks.Dataflow (31)
Blocks\ActionBlock.cs (31)
120dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _defaultTarget); 128Debug.Assert((_spscTarget != null) ^ (_defaultTarget != null), "One and only one of the two targets must be non-null after construction"); 136Debug.Assert(_defaultTarget != null); 150if (_defaultTarget.IsBounded) _defaultTarget.ChangeBoundingCount(-1); 160Debug.Assert(_defaultTarget != null); 179_defaultTarget.Complete(caughtException, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 183_defaultTarget.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 206Debug.Assert(_defaultTarget != null); 213_defaultTarget.Complete(completed.Exception, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true); 220_defaultTarget.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 226if (_defaultTarget != null) 228_defaultTarget.Complete(exception: null, dropPendingMessages: false); 245if (_defaultTarget != null) 247_defaultTarget.Complete(exception, dropPendingMessages: true); 259get { return _defaultTarget != null ? _defaultTarget.Completion : _spscTarget!.Completion; } 284return _defaultTarget != null ? 285_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatus.Accepted : 292return _defaultTarget != null ? 293_defaultTarget.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}"; 338if (_actionBlock._defaultTarget != null) 340_defaultDebugInfo = actionBlock._defaultTarget!.GetDebuggingInformation();