ProtectedEventStream::process can't consume the _queue

[gitbufenshuo]

                         // ProtectedEventStream::process method
                         if(limit >= _queue.size())
            {
                processEvents.reserve(_queue.size());
                std::swap(processEvents, _queue);
            }
            else
            {
                const auto countElements = std::min(limit, _queue.size());
                processEvents.reserve(countElements);
                std::move(_queue.begin(),
                          std::next(_queue.begin(), countElements),
                          std::back_inserter(processEvents));
                    // _queue.size() remains unchanged
                         }

[gelldur]

Thank you, fixed.