From e8724b605212c82090d79e07464ad724ec2ba50c Mon Sep 17 00:00:00 2001 From: Dawid Drozd Date: Thu, 24 Nov 2022 06:56:47 +0100 Subject: [PATCH] Fix ProtectedEventStream::process erase queue #46 --- lib/src/dexode/eventbus/stream/ProtectedEventStream.hpp | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/src/dexode/eventbus/stream/ProtectedEventStream.hpp b/lib/src/dexode/eventbus/stream/ProtectedEventStream.hpp index c4ea191..ca118c7 100644 --- a/lib/src/dexode/eventbus/stream/ProtectedEventStream.hpp +++ b/lib/src/dexode/eventbus/stream/ProtectedEventStream.hpp @@ -42,6 +42,7 @@ public: std::move(_queue.begin(), std::next(_queue.begin(), countElements), std::back_inserter(processEvents)); + _queue.erase(_queue, std::next(_queue.begin(), countElements)); } }