2 writes to _defaultTarget
System.Threading.Tasks.Dataflow (2)
Blocks\ActionBlock.cs (2)
99_defaultTarget = new TargetCore<TInput>(this, 107_defaultTarget = new TargetCore<TInput>(this,
31 references to _defaultTarget
System.Threading.Tasks.Dataflow (31)
Blocks\ActionBlock.cs (31)
114dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _defaultTarget); 122Debug.Assert((_spscTarget != null) ^ (_defaultTarget != null), "One and only one of the two targets must be non-null after construction"); 130Debug.Assert(_defaultTarget != null); 144if (_defaultTarget.IsBounded) _defaultTarget.ChangeBoundingCount(-1); 154Debug.Assert(_defaultTarget != null); 173_defaultTarget.Complete(caughtException, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 177_defaultTarget.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 200Debug.Assert(_defaultTarget != null); 207_defaultTarget.Complete(completed.Exception, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true); 214_defaultTarget.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 220if (_defaultTarget != null) 222_defaultTarget.Complete(exception: null, dropPendingMessages: false); 236if (_defaultTarget != null) 238_defaultTarget.Complete(exception, dropPendingMessages: true); 250get { return _defaultTarget != null ? _defaultTarget.Completion : _spscTarget!.Completion; } 275return _defaultTarget != null ? 276_defaultTarget.OfferMessage(Common.SingleMessageHeader, item, null, false) == DataflowMessageStatus.Accepted : 283return _defaultTarget != null ? 284_defaultTarget.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}"; 329if (_actionBlock._defaultTarget != null) 331_defaultDebugInfo = actionBlock._defaultTarget!.GetDebuggingInformation();