private async Task scanLoadAssignments()

in rocketmq-client-csharp/PushConsumer.cs [78:98]

19 lines of code
4 McCabe index (conditional complexity)


        private async Task scanLoadAssignments()
        {
            Logger.Debug("Start to scan load assignments from server");
            List<Task<List<rmq::Assignment>>> tasks = new List<Task<List<rmq::Assignment>>>();
            foreach (var item in _topicFilterExpressionMap)
            {
                tasks.Add(scanLoadAssignment(item.Key, _group));
            }
            var result = await Task.WhenAll(tasks);

            foreach (var assignments in result)
            {
                if (assignments.Count == 0)
                {
                    continue;
                }

                checkAndUpdateAssignments(assignments);
            }
            Logger.Debug("Completed scanning load assignments");
        }