16 references to ChangeBoundingCount
System.Threading.Tasks.Dataflow (16)
Blocks\ActionBlock.cs (1)
144if (_defaultTarget.IsBounded) _defaultTarget.ChangeBoundingCount(-1);
Blocks\TransformBlock.cs (3)
106onItemsRemoved = static (owningSource, count) => ((TransformBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 190if (!itemIsValid) _target.ChangeBoundingCount(-1); 299if (!gotOutputItem && isBounded) _target.ChangeBoundingCount(-1);
Blocks\TransformManyBlock.cs (7)
115onItemsRemoved = static (owningSource, count) => ((TransformManyBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 339_target.ChangeBoundingCount(count: -1); 361if (isBounded) target.ChangeBoundingCount(count: -1); 484if (outputFirstItem) _target.ChangeBoundingCount(count: 1); 502if (!outputFirstItem) _target.ChangeBoundingCount(count: -1); 539if (count > 1) _target.ChangeBoundingCount(count - 1); 540else if (count == 0) _target.ChangeBoundingCount(-1);
Blocks\TransformManyBlock.IAsyncEnumerable.cs (4)
108_target.ChangeBoundingCount(count: -1); 132target.ChangeBoundingCount(count: -1); 219_target.ChangeBoundingCount(count: 1); 240_target.ChangeBoundingCount(count: -1);
Internal\TargetCore.cs (1)
695ChangeBoundingCount(-1);