private void ScanExpiredProcessQueue()

in rocketmq-client-csharp/PushConsumer.cs [100:112]

• 13 lines of code
• 3 McCabe index (conditional complexity)

        private void ScanExpiredProcessQueue()
        {
            foreach (var item in _processQueueMap)
            {
                if (item.Value.Expired())
                {
                    Task.Run(async () =>
                    {
                        await ExecutePop0(item.Key);
                    });
                }
            }
        }