public override async Task Start()

in rocketmq-client-csharp/SimpleConsumer.cs [59:73]

12 lines of code
2 McCabe index (conditional complexity)


        public override async Task Start()
        {
            await base.Start();
            
            // Scan load assignment periodically
            schedule(async () =>
            {
                while (!_scanAssignmentCts.IsCancellationRequested)
                {
                    await ScanLoadAssignments();                    
                }
            }, 30, _scanAssignmentCts.Token);

            await ScanLoadAssignments();
        }