private void ExecutePop()

in rocketmq-client-csharp/PushConsumer.cs [149:159]

• 11 lines of code
• 2 McCabe index (conditional complexity)

        private void ExecutePop(rmq::Assignment assignment)
        {
            var processQueue = new ProcessQueue();
            if (_processQueueMap.TryAdd(assignment, processQueue))
            {
                Task.Run(async () =>
                {
                    await ExecutePop0(assignment);
                });
            }
        }