commit 737f2de0bdaf220f133083d4e902f26f0d898ba7
author Saurab Dulal <sdulal@memphis.edu> Wed Nov 09 17:14:46 2022 +0000
committer Saurab Dulal <sdulal@memphis.edu> Tue Nov 22 04:53:29 2022 +0000
tree 16b06cbba13c573736b8bd5ca21ddf6aec289dcd
parent b68f28497e29a5cfcbb5ae2de33956f34e814760

partial-sync: add unsubscribe feature

Change-Id: Ib32aa2c0acebb5be40bb8d99689a3ea18113a692

tests/test-consumer.cpp

diff --git a/tests/test-consumer.cpp b/tests/test-consumer.cpp
index 79ee495..62715bb 100644
--- a/tests/test-consumer.cpp
+++ b/tests/test-consumer.cpp
@@ -45,6 +45,23 @@
   BOOST_CHECK(!consumer.addSubscription(subscription, 0));
 }
 
+BOOST_AUTO_TEST_CASE(RemoveSubscription)
+{
+  util::DummyClientFace face;
+  Consumer consumer(Name("/psync"), face,
+                    [] (const auto&) {},
+                    [] (const auto&) {},
+                    40, 0.001);
+
+  Name subscription("test");
+  consumer.addSubscription(subscription, 0);
+
+  BOOST_CHECK(consumer.isSubscribed(subscription));
+  BOOST_CHECK(consumer.removeSubscription(subscription));
+  BOOST_CHECK(!consumer.removeSubscription(subscription));
+  BOOST_CHECK(!consumer.isSubscribed(subscription));
+}
+
 BOOST_FIXTURE_TEST_CASE(ConstantTimeoutForFirstSegment, tests::IoFixture)
 {
   util::DummyClientFace face(m_io);