tqcq/ulib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat/add_eventbus #9

Merged
tqcq merged 7 commits from feat/add_eventbus into develop 2024-01-19 12:51:30 +08:00
Conversation 0 Commits 7 Files Changed 8 +4 -4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 377613c9ba - Show all commits

8
3party/EventBus/lib/src/dexode/eventbus/stream/ProtectedEventStream.hpp
View File

@ -18,9 +18,9 @@ class ProtectedEventStream : public EventStream
using Callback = std::function<CallbackReturn(const Event&, ExtraArgTypes...)>; using Callback = std::function<CallbackReturn(const Event&, ExtraArgTypes...)>;
public: public:
void postpone(std::any event) override void postpone(nonstd::any event) override
{ {
auto myEvent = std::any_cast<Event>(event); auto myEvent = nonstd::any_cast<Event>(event);
std::lock_guard writeGuard{_mutexEvent}; std::lock_guard writeGuard{_mutexEvent};
_queue.push_back(std::move(myEvent)); _queue.push_back(std::move(myEvent));
} }
@ -67,10 +67,10 @@ public:
return processEvents.size(); return processEvents.size();
} }
bool addListener(const std::uint32_t listenerID, std::any callback) override bool addListener(const std::uint32_t listenerID, nonstd::any callback) override
{ {
std::lock_guard writeGuard{_mutexCallbacks}; std::lock_guard writeGuard{_mutexCallbacks};
auto myCallback = std::any_cast<Callback>(callback); auto myCallback = nonstd::any_cast<Callback>(callback);
if(_isProcessing) if(_isProcessing)
{ {
_waiting.emplace_back(listenerID, std::move(myCallback)); _waiting.emplace_back(listenerID, std::move(myCallback));