private void HandleBatchSizeReduction()

in src/Epam.Kafka.PubSub/Common/PubSubBackgroundService.cs [281:293]

• 12 lines of code
• 5 McCabe index (conditional complexity)

    private void HandleBatchSizeReduction(int i)
    {
        if (this.AdaptiveBatchSize.HasValue && this.AdaptiveBatchSize > 1 &&
            i >= this.Options.ReduceBatchSizeRetryIteration)
        {
            this.AdaptiveBatchSize /= 2;

            if (this.AdaptiveBatchSize < 1)
            {
                this.AdaptiveBatchSize = 1;
            }
        }
    }