2 writes to _target
System.Threading.Tasks.Dataflow (2)
Blocks\TransformBlock.cs (2)
122_target = new TargetCore<TInput>(this, 129_target = new TargetCore<TInput>(this,
19 references to _target
System.Threading.Tasks.Dataflow (19)
Blocks\TransformBlock.cs (19)
105onItemsRemoved = static (owningSource, count) => ((TransformBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 109static owningSource => ((TransformBlock<TInput, TOutput>)owningSource)._target.Complete(exception: null, dropPendingMessages: true), 139_target.Completion.ContinueWith(static (completed, state) => 159dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _target); 189if (!itemIsValid) _target.ChangeBoundingCount(-1); 202if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 243_target.Complete(caughtException, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 251_target.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 272bool isBounded = _target.IsBounded; 288_target.Complete(aggregate, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true); 298if (!gotOutputItem && isBounded) _target.ChangeBoundingCount(-1); 306if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 325_target.SignalOneAsyncMessageCompleted(); 329public void Complete() { _target.Complete(exception: null, dropPendingMessages: false); } 336_target.Complete(exception, dropPendingMessages: true); 358public int InputCount { get { return _target.InputCount; } } 366return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); 388private int InputCountForDebugger { get { return _target.GetDebuggingInformation().InputCount; } } 418_targetDebuggingInformation = transformBlock._target.GetDebuggingInformation();