diff --git a/lib/include/dexode/EventBus.hpp b/lib/include/dexode/EventBus.hpp index d69e295..b8d06c0 100644 --- a/lib/include/dexode/EventBus.hpp +++ b/lib/include/dexode/EventBus.hpp @@ -5,10 +5,8 @@ #include #include -#include - #include - +#include #include "eventbus/Listener.hpp" #include "eventbus/Subscriber.hpp" diff --git a/lib/src/dexode/eventbus/strategy/Protected.cpp b/lib/src/dexode/eventbus/strategy/Protected.cpp index 3b7c376..8caed2d 100644 --- a/lib/src/dexode/eventbus/strategy/Protected.cpp +++ b/lib/src/dexode/eventbus/strategy/Protected.cpp @@ -43,6 +43,7 @@ bool Protected::wait() std::shared_lock readLock{_mutex}; return not _eventQueue.empty(); } + bool Protected::waitFor(std::chrono::milliseconds timeout) { using namespace std::chrono_literals;