Function TEST

test/concurrent/test_transient_topic.cpp:10–27

using ::babylon::ConcurrentTransientTopic;

TEST(concurrent_transient_topic, movable) {
  ConcurrentTransientTopic<::std::string> topic;
  topic.publish("1");
  topic.publish("2");
  ConcurrentTransientTopic<::std::string> moved_topic(::std::move(topic));
  ConcurrentTransientTopic<::std::string> move_assigned_topic;
  move_assigned_topic = ::std::move(moved_topic);
  move_assigned_topic.publish("3");
  move_assigned_topic.publish("4");
  move_assigned_topic.close();

  auto consumer = move_assigned_topic.subscribe();
  ASSERT_EQ("1", *consumer.consume());
  ASSERT_EQ("2", *consumer.consume());
  ASSERT_EQ("3", *consumer.consume());
  ASSERT_EQ("4", *consumer.consume());
  ASSERT_EQ(nullptr, consumer.consume());
}

TEST(concurrent_transient_topic, publish_consume_fifo) {
  ConcurrentTransientTopic<::std::string> topic;