2 writes to _target
System.Threading.Tasks.Dataflow (2)
Blocks\TransformBlock.cs (2)
126_target = new TargetCore<TInput>(this, 133_target = new TargetCore<TInput>(this,
19 references to _target
System.Threading.Tasks.Dataflow (19)
Blocks\TransformBlock.cs (19)
109onItemsRemoved = static (owningSource, count) => ((TransformBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 113static owningSource => ((TransformBlock<TInput, TOutput>)owningSource)._target.Complete(exception: null, dropPendingMessages: true), 143_target.Completion.ContinueWith(static (completed, state) => 163dataflowBlockOptions.CancellationToken, Completion, static (state, _) => ((TargetCore<TInput>)state!).Complete(exception: null, dropPendingMessages: true), _target); 193if (!itemIsValid) _target.ChangeBoundingCount(-1); 206if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 247_target.Complete(caughtException, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 255_target.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 276bool isBounded = _target.IsBounded; 292_target.Complete(aggregate, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true); 302if (!gotOutputItem && isBounded) _target.ChangeBoundingCount(-1); 310if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 329_target.SignalOneAsyncMessageCompleted(); 333public void Complete() { _target.Complete(exception: null, dropPendingMessages: false); } 343_target.Complete(exception, dropPendingMessages: true); 365public int InputCount { get { return _target.InputCount; } } 373return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); 395private int InputCountForDebugger { get { return _target.GetDebuggingInformation().InputCount; } } 425_targetDebuggingInformation = transformBlock._target.GetDebuggingInformation();