Loading src/sled/event_bus/event_bus.h +2 −0 Original line number Diff line number Diff line Loading @@ -148,6 +148,8 @@ public: } } EventBus *operator->() { return this; } private: sled::Mutex mutex_; std::unordered_map<std::type_index, std::function<void(EventBus *)>> cleanup_handlers_ GUARDED_BY(mutex_); Loading src/sled/event_bus/event_bus_test.cc +1 −1 Original line number Diff line number Diff line Loading @@ -89,7 +89,7 @@ TEST_SUITE("EventBus") std::atomic<int> &data; }; struct AotmicEventSubscriber : public sled::EventBus::Subscriber { struct AotmicEventSubscriber : public sled::EventBus::Subscriber<> { virtual ~AotmicEventSubscriber() = default; void OnEvent(AtomicEvent event) { event.data.fetch_add(1); } Loading Loading
src/sled/event_bus/event_bus.h +2 −0 Original line number Diff line number Diff line Loading @@ -148,6 +148,8 @@ public: } } EventBus *operator->() { return this; } private: sled::Mutex mutex_; std::unordered_map<std::type_index, std::function<void(EventBus *)>> cleanup_handlers_ GUARDED_BY(mutex_); Loading
src/sled/event_bus/event_bus_test.cc +1 −1 Original line number Diff line number Diff line Loading @@ -89,7 +89,7 @@ TEST_SUITE("EventBus") std::atomic<int> &data; }; struct AotmicEventSubscriber : public sled::EventBus::Subscriber { struct AotmicEventSubscriber : public sled::EventBus::Subscriber<> { virtual ~AotmicEventSubscriber() = default; void OnEvent(AtomicEvent event) { event.data.fetch_add(1); } Loading