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));
 			}
 		}