2 writes to _target
System.Threading.Tasks.Dataflow (2)
Blocks\TransformBlock.cs (2)
123_target = new TargetCore<TInput>(this, 130_target = new TargetCore<TInput>(this,
19 references to _target
System.Threading.Tasks.Dataflow (19)
Blocks\TransformBlock.cs (19)
106onItemsRemoved = static (owningSource, count) => ((TransformBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 110static owningSource => ((TransformBlock<TInput, TOutput>)owningSource)._target.Complete(exception: null, dropPendingMessages: true), 140_target.Completion.ContinueWith(static (completed, state) => 160dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _target); 190if (!itemIsValid) _target.ChangeBoundingCount(-1); 203if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 244_target.Complete(caughtException, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 252_target.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 273bool isBounded = _target.IsBounded; 289_target.Complete(aggregate, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true); 299if (!gotOutputItem && isBounded) _target.ChangeBoundingCount(-1); 307if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 326_target.SignalOneAsyncMessageCompleted(); 330public void Complete() { _target.Complete(exception: null, dropPendingMessages: false); } 337_target.Complete(exception, dropPendingMessages: true); 359public int InputCount { get { return _target.InputCount; } } 367return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); 389private int InputCountForDebugger { get { return _target.GetDebuggingInformation().InputCount; } } 419_targetDebuggingInformation = transformBlock._target.GetDebuggingInformation();