8 references to ActualMaxNumberOfGroups
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (6)
392
(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
)
505
bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
;
565
bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
;
741
if (_batchesCompleted >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
) _decliningPermanently = true;
837
(_batchesCompleted + 1) >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
)
949
(_batchesCompleted + 1) >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
)
Blocks\BatchedJoinBlock.cs (1)
708
if (_batchesCreated >= dataflowBlockOptions.
ActualMaxNumberOfGroups
) _allTargetsDecliningPermanentlyAction();
Blocks\JoinBlock.cs (1)
732
if ((_sharedResources._joinsCreated + messageCount) >= _sharedResources._dataflowBlockOptions.
ActualMaxNumberOfGroups
)