FairMQ/fairmq/test/event_manager/_event_manager.cxx
Dennis Klein b7d97f6306 FairMQ: Support Apple Compiler 8.0
In fact, this commit will workaround a bug with template alias compilation
from Clang 3.4 to Clang 3.8.
2017-10-12 12:16:50 +02:00

65 lines
2.2 KiB
C++

/********************************************************************************
* Copyright (C) 2017 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH *
* *
* This software is distributed under the terms of the *
* GNU Lesser General Public Licence (LGPL) version 3, *
* copied verbatim in the file "LICENSE" *
********************************************************************************/
#include <gtest/gtest.h>
#include <fairmq/EventManager.h>
#include <string>
namespace
{
using namespace std;
using namespace fair::mq;
struct TestEvent : fair::mq::Event<const std::string&> {};
TEST(EventManager, Basics)
{
EventManager mgr{};
int call_counter = 0;
int call_counter2 = 0;
int value = 0;
string value2;
std::function<void(typename TestEvent::KeyType, int)> callback{
[&](TestEvent::KeyType key, int newValue){
++call_counter;
if (key == "test") value = newValue;
}
};
std::function<void(typename TestEvent::KeyType, string)> callback2{
[&](TestEvent::KeyType key, string newValue){
++call_counter2;
if (key == "test") value2 = newValue;
}
};
mgr.Subscribe<TestEvent, int>("foo_subscriber", callback);
// double subscription will automatically unsubscribe first
mgr.Subscribe<TestEvent, int>("foo_subscriber", callback);
mgr.Emit<TestEvent>(TestEvent::KeyType{"test"}, 42);
ASSERT_EQ(call_counter, 1);
ASSERT_EQ(value, 42);
mgr.Unsubscribe<TestEvent, int>("foo_subscriber");
mgr.Emit<TestEvent>(TestEvent::KeyType{"test"}, 13);
ASSERT_EQ(call_counter, 1);
mgr.Subscribe<TestEvent, int>("foo_subscriber", callback);
mgr.Subscribe<TestEvent, string>("foo_subscriber", callback2);
// two different callbacks:
mgr.Emit<TestEvent>(TestEvent::KeyType{"test"}, 9000);
mgr.Emit<TestEvent>(TestEvent::KeyType{"test"}, string{"over 9000"});
ASSERT_EQ(call_counter, 2);
ASSERT_EQ(value, 9000);
ASSERT_EQ(call_counter2, 1);
ASSERT_EQ(value2, "over 9000");
}
} // namespace