_target

3 writes to _target

System.Threading.Tasks.Dataflow (3)

Blocks\TransformManyBlock.cs (2)

71Initialize(messageWithId => ProcessMessage(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.None); 95Initialize(messageWithId => ProcessMessageWithTask(transform, messageWithId), dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);

Blocks\TransformManyBlock.IAsyncEnumerable.cs (1)

45}, dataflowBlockOptions, ref _source, ref _target, ref _reorderingBuffer, TargetCoreOptions.UsesAsyncCompletion);

35 references to _target

System.Threading.Tasks.Dataflow (35)

Blocks\TransformManyBlock.cs (26)

115onItemsRemoved = static (owningSource, count) => ((TransformManyBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 120static owningSource => ((TransformManyBlock<TInput, TOutput>)owningSource)._target.Complete(exception: null, dropPendingMessages: true), 214_target.Complete(caughtException, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 224_target.SignalOneAsyncMessageCompleted(); 232_target.SignalOneAsyncMessageCompleted(boundingCountChange: -1); 278_target.Complete(exc, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 288_target.Complete(aggregate, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: true); 300_target.SignalOneAsyncMessageCompleted(); 333else if (_target.IsBounded) 339_target.ChangeBoundingCount(count: -1); 354TargetCore<TInput> target = _target; 440if (_target.IsBounded) UpdateBoundingCountWithOutputCount(count: ((ICollection<TOutput>)outputItems).Count); 442if (_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1) 468_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1 || 473if (_target.IsBounded) 484if (outputFirstItem) _target.ChangeBoundingCount(count: 1); 502if (!outputFirstItem) _target.ChangeBoundingCount(count: -1); 538Debug.Assert(_target.IsBounded, "Expected to be in bounding mode."); 539if (count > 1) _target.ChangeBoundingCount(count - 1); 540else if (count == 0) _target.ChangeBoundingCount(-1); 545public void Complete() { _target.Complete(exception: null, dropPendingMessages: false); } 555_target.Complete(exception, dropPendingMessages: true); 571public int InputCount { get { return _target.InputCount; } } 579return _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept); 601private int InputCountForDebugger { get { return _target.GetDebuggingInformation().InputCount; } } 631_targetDebuggingInformation = transformManyBlock._target.GetDebuggingInformation();

Blocks\TransformManyBlock.IAsyncEnumerable.cs (9)

75_target.Complete(exc, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, unwrapInnerExceptions: false); 81_target.SignalOneAsyncMessageCompleted(); 105else if (_target.IsBounded) 111_target.ChangeBoundingCount(count: -1); 126TargetCore<TInput> target = _target; 204_target.DataflowBlockOptions.MaxDegreeOfParallelism == 1 || 209if (_target.IsBounded) 222_target.ChangeBoundingCount(count: 1); 243_target.ChangeBoundingCount(count: -1);