8 references to ActualMaxNumberOfGroups
System.Threading.Tasks.Dataflow (8)
Blocks\BatchBlock.cs (6)
395
(_batchesCompleted + (_messages.Count / _batchSize)) >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
)
508
bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
;
568
bool completedAllDesiredBatches = _batchesCompleted >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
;
744
if (_batchesCompleted >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
) _decliningPermanently = true;
840
(_batchesCompleted + 1) >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
)
952
(_batchesCompleted + 1) >= _dataflowBlockOptions.
ActualMaxNumberOfGroups
)
Blocks\BatchedJoinBlock.cs (1)
717
if (_batchesCreated >= dataflowBlockOptions.
ActualMaxNumberOfGroups
) _allTargetsDecliningPermanentlyAction();
Blocks\JoinBlock.cs (1)
744
if ((_sharedResources._joinsCreated + messageCount) >= _sharedResources._dataflowBlockOptions.
ActualMaxNumberOfGroups
)