16 references to ChangeBoundingCount
System.Threading.Tasks.Dataflow (16)
Blocks\ActionBlock.cs (1)
150if (_defaultTarget.IsBounded) _defaultTarget.ChangeBoundingCount(-1);
Blocks\TransformBlock.cs (3)
109onItemsRemoved = static (owningSource, count) => ((TransformBlock<TInput, TOutput>)owningSource)._target.ChangeBoundingCount(-count); 193if (!itemIsValid) _target.ChangeBoundingCount(-1); 302if (!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)
111_target.ChangeBoundingCount(count: -1); 135target.ChangeBoundingCount(count: -1); 222_target.ChangeBoundingCount(count: 1); 243_target.ChangeBoundingCount(count: -1);
Internal\TargetCore.cs (1)
695ChangeBoundingCount(-1);