diff --git a/src/EventManager/EventListener.hpp b/src/EventManager/EventListener.hpp index 08ad74ae..279e3a30 100644 --- a/src/EventManager/EventListener.hpp +++ b/src/EventManager/EventListener.hpp @@ -180,8 +180,7 @@ namespace Bloom */ template auto waitForEvent( - std::optional timeout = std::nullopt, - std::optional correlationId = std::nullopt + std::optional timeout = std::nullopt ) { // Different return types, depending on how many event type arguments are passed in. using MonoType = std::optional>; @@ -246,25 +245,16 @@ namespace Bloom } Events::SharedGenericEventPointer foundEvent = nullptr; - auto eventsFound = [&eventTypes, &eventQueueByType, &correlationId, &foundEvent] () -> bool { + auto eventsFound = [&eventTypes, &eventQueueByType, &foundEvent] () -> bool { for (const auto& eventType : eventTypes) { if (eventQueueByType.find(eventType) != eventQueueByType.end() && !eventQueueByType.find(eventType)->second.empty() ) { auto& queue = eventQueueByType.find(eventType)->second; while (!queue.empty()) { - auto event = queue.front(); - - if (!correlationId.has_value() - || (event->correlationId.has_value() && event->correlationId == correlationId) - ) { - foundEvent = event; - queue.pop(); - return true; - } - - // Events that match in type but not correlation ID are discarded + foundEvent = queue.front(); queue.pop(); + return true; } } } diff --git a/src/EventManager/Events/Event.hpp b/src/EventManager/Events/Event.hpp index c2c137d7..cdc247ac 100644 --- a/src/EventManager/Events/Event.hpp +++ b/src/EventManager/Events/Event.hpp @@ -38,7 +38,6 @@ namespace Bloom::Events public: int id = ++(Event::lastEventId); QDateTime createdTimestamp = DateTime::currentDateTime(); - std::optional correlationId; static constexpr EventType type = EventType::GENERIC; static inline const std::string name = "GenericEvent";