Mercurial > hg > orthanc-stone
diff UnitTestsSources/TestMessageBroker.cpp @ 624:573e35378999
fix
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Tue, 07 May 2019 14:28:10 +0200 |
parents | 8adc8cfb50c7 |
children | f0008c55e5f7 |
line wrap: on
line diff
--- a/UnitTestsSources/TestMessageBroker.cpp Tue May 07 14:16:08 2019 +0200 +++ b/UnitTestsSources/TestMessageBroker.cpp Tue May 07 14:28:10 2019 +0200 @@ -160,18 +160,18 @@ observable.RegisterObserverCallback(new Callable<MyObserver, MyObservable::MyCustomMessage>(observer, &MyObserver::HandleCompletedMessage)); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(12, testCounter); // the connection is permanent; if we emit the same message again, the observer will be notified again testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(20, testCounter); // Unregister the observer; make sure it's not called anymore observable.Unregister(&observer); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(0, testCounter); } @@ -186,12 +186,12 @@ intermediate.RegisterObserverCallback(new Callable<MyObserver, MyObservable::MyCustomMessage>(observer, &MyObserver::HandleCompletedMessage)); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(12, testCounter); // the connection is permanent; if we emit the same message again, the observer will be notified again testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(20, testCounter); } @@ -205,7 +205,7 @@ observable.RegisterObserverCallback(new Callable<MyObserver, MyObservable::MyCustomMessage>(*observer, &MyObserver::HandleCompletedMessage)); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(12, testCounter); // delete the observer and check that the callback is not called anymore @@ -213,7 +213,7 @@ // the connection is permanent; if we emit the same message again, the observer will be notified again testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(0, testCounter); } @@ -228,12 +228,12 @@ intermediate->RegisterObserverCallback(new Callable<MyObserver, MyObservable::MyCustomMessage>(observer, &MyObserver::HandleCompletedMessage)); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(12, testCounter); delete intermediate; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(12, testCounter); } @@ -248,12 +248,12 @@ intermediate.RegisterObserverCallback(new Callable<MyObserver, MyObservable::MyCustomMessage>(observer, &MyObserver::HandleCompletedMessage)); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(12, testCounter); // the connection is permanent; if we emit the same message again, the observer will be notified again testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(20, testCounter); } @@ -324,7 +324,7 @@ observable.RegisterObserverCallback(new LambdaCallable<MyObservable::MyCustomMessage>(*observer, [&](const MyObservable::MyCustomMessage& message) {testCounter += 2 * message.payload_;})); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(24, testCounter); // delete the observer and check that the callback is not called anymore @@ -332,7 +332,7 @@ // the connection is permanent; if we emit the same message again, the observer will be notified again testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(0, testCounter); } @@ -362,7 +362,7 @@ MyObserverWithLambda* observer = new MyObserverWithLambda(broker, 3, observable); testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(12)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(12)); ASSERT_EQ(36, testCounter); // delete the observer and check that the callback is not called anymore @@ -370,7 +370,7 @@ // the connection is permanent; if we emit the same message again, the observer will be notified again testCounter = 0; - observable.EmitMessage(MyObservable::MyCustomMessage(20)); + observable.BroadcastMessage(MyObservable::MyCustomMessage(20)); ASSERT_EQ(0, testCounter); }