|
|
@@ -35,9 +35,11 @@ public:
|
|
|
friend class SubscriptionRegistry<EventExample>;
|
|
|
};
|
|
|
|
|
|
-class ListenerMock
|
|
|
+class EventBusListenerMock
|
|
|
{
|
|
|
public:
|
|
|
+ virtual ~EventBusListenerMock() = default;
|
|
|
+
|
|
|
MOCK_METHOD1(beforeEvent, void(EventExample &));
|
|
|
MOCK_METHOD1(onEvent, void(EventExample &));
|
|
|
MOCK_METHOD1(afterEvent, void(const EventExample &));
|
|
|
@@ -51,9 +53,9 @@ public:
|
|
|
EventBus subject1;
|
|
|
EventBus subject2;
|
|
|
|
|
|
- StrictMock<ListenerMock> listener;
|
|
|
- StrictMock<ListenerMock> listener1;
|
|
|
- StrictMock<ListenerMock> listener2;
|
|
|
+ StrictMock<EventBusListenerMock> listener;
|
|
|
+ StrictMock<EventBusListenerMock> listener1;
|
|
|
+ StrictMock<EventBusListenerMock> listener2;
|
|
|
};
|
|
|
|
|
|
TEST_F(EventBusTest, ExecuteNoListeners)
|
|
|
@@ -67,15 +69,15 @@ TEST_F(EventBusTest, ExecuteNoListenersWithHandler)
|
|
|
EXPECT_CALL(event1, isEnabled()).WillRepeatedly(Return(true));
|
|
|
EXPECT_CALL(listener, onEvent(Ref(event1))).Times(1);
|
|
|
|
|
|
- subject1.executeEvent(event1, std::bind(&ListenerMock::onEvent, &listener, _1));
|
|
|
+ subject1.executeEvent(event1, std::bind(&EventBusListenerMock::onEvent, &listener, _1));
|
|
|
}
|
|
|
|
|
|
TEST_F(EventBusTest, ExecuteIgnoredSubscription)
|
|
|
{
|
|
|
EXPECT_CALL(event1, isEnabled()).WillRepeatedly(Return(true));
|
|
|
|
|
|
- subject1.subscribeBefore<EventExample>(std::bind(&ListenerMock::beforeEvent, &listener, _1));
|
|
|
- subject1.subscribeAfter<EventExample>(std::bind(&ListenerMock::afterEvent, &listener, _1));
|
|
|
+ subject1.subscribeBefore<EventExample>(std::bind(&EventBusListenerMock::beforeEvent, &listener, _1));
|
|
|
+ subject1.subscribeAfter<EventExample>(std::bind(&EventBusListenerMock::afterEvent, &listener, _1));
|
|
|
|
|
|
EXPECT_CALL(listener, beforeEvent(_)).Times(0);
|
|
|
EXPECT_CALL(listener, afterEvent(_)).Times(0);
|
|
|
@@ -87,10 +89,10 @@ TEST_F(EventBusTest, ExecuteSequence)
|
|
|
{
|
|
|
EXPECT_CALL(event1, isEnabled()).WillRepeatedly(Return(true));
|
|
|
|
|
|
- auto subscription1 = subject1.subscribeBefore<EventExample>(std::bind(&ListenerMock::beforeEvent, &listener1, _1));
|
|
|
- auto subscription2 = subject1.subscribeAfter<EventExample>(std::bind(&ListenerMock::afterEvent, &listener1, _1));
|
|
|
- auto subscription3 = subject1.subscribeBefore<EventExample>(std::bind(&ListenerMock::beforeEvent, &listener2, _1));
|
|
|
- auto subscription4 = subject1.subscribeAfter<EventExample>(std::bind(&ListenerMock::afterEvent, &listener2, _1));
|
|
|
+ auto subscription1 = subject1.subscribeBefore<EventExample>(std::bind(&EventBusListenerMock::beforeEvent, &listener1, _1));
|
|
|
+ auto subscription2 = subject1.subscribeAfter<EventExample>(std::bind(&EventBusListenerMock::afterEvent, &listener1, _1));
|
|
|
+ auto subscription3 = subject1.subscribeBefore<EventExample>(std::bind(&EventBusListenerMock::beforeEvent, &listener2, _1));
|
|
|
+ auto subscription4 = subject1.subscribeAfter<EventExample>(std::bind(&EventBusListenerMock::afterEvent, &listener2, _1));
|
|
|
|
|
|
{
|
|
|
InSequence sequence;
|
|
|
@@ -101,17 +103,17 @@ TEST_F(EventBusTest, ExecuteSequence)
|
|
|
EXPECT_CALL(listener2, afterEvent(Ref(event1))).Times(1);
|
|
|
}
|
|
|
|
|
|
- subject1.executeEvent(event1, std::bind(&ListenerMock::onEvent, &listener, _1));
|
|
|
+ subject1.executeEvent(event1, std::bind(&EventBusListenerMock::onEvent, &listener, _1));
|
|
|
}
|
|
|
|
|
|
TEST_F(EventBusTest, BusesAreIndependent)
|
|
|
{
|
|
|
EXPECT_CALL(event1, isEnabled()).WillRepeatedly(Return(true));
|
|
|
|
|
|
- auto subscription1 = subject1.subscribeBefore<EventExample>(std::bind(&ListenerMock::beforeEvent, &listener1, _1));
|
|
|
- auto subscription2 = subject1.subscribeAfter<EventExample>(std::bind(&ListenerMock::afterEvent, &listener1, _1));
|
|
|
- auto subscription3 = subject2.subscribeBefore<EventExample>(std::bind(&ListenerMock::beforeEvent, &listener2, _1));
|
|
|
- auto subscription4 = subject2.subscribeAfter<EventExample>(std::bind(&ListenerMock::afterEvent, &listener2, _1));
|
|
|
+ auto subscription1 = subject1.subscribeBefore<EventExample>(std::bind(&EventBusListenerMock::beforeEvent, &listener1, _1));
|
|
|
+ auto subscription2 = subject1.subscribeAfter<EventExample>(std::bind(&EventBusListenerMock::afterEvent, &listener1, _1));
|
|
|
+ auto subscription3 = subject2.subscribeBefore<EventExample>(std::bind(&EventBusListenerMock::beforeEvent, &listener2, _1));
|
|
|
+ auto subscription4 = subject2.subscribeAfter<EventExample>(std::bind(&EventBusListenerMock::afterEvent, &listener2, _1));
|
|
|
|
|
|
EXPECT_CALL(listener1, beforeEvent(_)).Times(1);
|
|
|
EXPECT_CALL(listener2, beforeEvent(_)).Times(0);
|
|
|
@@ -125,7 +127,7 @@ TEST_F(EventBusTest, DisabledTestDontExecute)
|
|
|
{
|
|
|
EXPECT_CALL(event1, isEnabled()).Times(AtLeast(1)).WillRepeatedly(Return(false));
|
|
|
EXPECT_CALL(listener, onEvent(Ref(event1))).Times(0);
|
|
|
- subject1.executeEvent(event1, std::bind(&ListenerMock::onEvent, &listener, _1));
|
|
|
+ subject1.executeEvent(event1, std::bind(&EventBusListenerMock::onEvent, &listener, _1));
|
|
|
}
|
|
|
|
|
|
TEST_F(EventBusTest, DisabledTestDontExecutePostHandler)
|
|
|
@@ -134,10 +136,10 @@ TEST_F(EventBusTest, DisabledTestDontExecutePostHandler)
|
|
|
EXPECT_CALL(listener, onEvent(Ref(event1))).WillRepeatedly(Return());
|
|
|
EXPECT_CALL(listener1, afterEvent(Ref(event1))).Times(0);
|
|
|
|
|
|
- auto subscription1 = subject1.subscribeAfter<EventExample>(std::bind(&ListenerMock::afterEvent, &listener1, _1));
|
|
|
+ auto subscription1 = subject1.subscribeAfter<EventExample>(std::bind(&EventBusListenerMock::afterEvent, &listener1, _1));
|
|
|
|
|
|
|
|
|
- subject1.executeEvent(event1, std::bind(&ListenerMock::onEvent, &listener, _1));
|
|
|
+ subject1.executeEvent(event1, std::bind(&EventBusListenerMock::onEvent, &listener, _1));
|
|
|
}
|
|
|
|
|
|
TEST_F(EventBusTest, DisabledTestExecutePreHandler)
|
|
|
@@ -146,9 +148,9 @@ TEST_F(EventBusTest, DisabledTestExecutePreHandler)
|
|
|
EXPECT_CALL(listener, onEvent(Ref(event1))).WillRepeatedly(Return());
|
|
|
EXPECT_CALL(listener1, beforeEvent(Ref(event1))).Times(1);
|
|
|
|
|
|
- auto subscription1 = subject1.subscribeBefore<EventExample>(std::bind(&ListenerMock::beforeEvent, &listener1, _1));
|
|
|
+ auto subscription1 = subject1.subscribeBefore<EventExample>(std::bind(&EventBusListenerMock::beforeEvent, &listener1, _1));
|
|
|
|
|
|
- subject1.executeEvent(event1, std::bind(&ListenerMock::onEvent, &listener, _1));
|
|
|
+ subject1.executeEvent(event1, std::bind(&EventBusListenerMock::onEvent, &listener, _1));
|
|
|
}
|
|
|
|
|
|
|