private void CancelPop()

in rocketmq-client-csharp/PushConsumer.cs [213:225]


        private void CancelPop(rmq::Assignment assignment)
        {
            if (!_processQueueMap.ContainsKey(assignment))
            {
                return;
            }

            ProcessQueue processQueue;
            if (_processQueueMap.Remove(assignment, out processQueue))
            {
                processQueue.Dropped = true;
            }
        }