rpclib
diff --git a/‎tests/rpc/this_server_test.cc
Copy file name to clipboardExpand all lines: tests/rpc/this_server_test.cc
+21-1Lines changed: 21 additions & 1 deletion b/‎tests/rpc/this_server_test.cc
Copy file name to clipboardExpand all lines: tests/rpc/this_server_test.cc
+21-1Lines changed: 21 additions & 1 deletion
@@ -1,5 +1,7 @@
 #include "gtest/gtest.h"
 
+#include <future>
+
 #include "rpc/client.h"
 #include "rpc/server.h"
 #include "rpc/this_server.h"
@@ -24,7 +26,7 @@ class this_server_test : public testing::Test {
     rpc::client c2;
 };
 
-TEST_F(this_server_test, stop) {
+TEST_F(this_server_test, stop_async) {
     s.bind("stop_server", []() { rpc::this_server().stop(); });
     s.async_run();
     c1.call("stop_server");
@@ -35,3 +37,21 @@ TEST_F(this_server_test, stop) {
     EXPECT_EQ(c2.get_connection_state(),
               client::connection_state::disconnected);
 }
+
+TEST_F(this_server_test, stop_sync) {
+    s.bind("stop_server", []() { rpc::this_server().stop(); });
+
+    auto handle = std::async(std::launch::async, [this]() {
+        std::this_thread::sleep_for(std::chrono::milliseconds(100));
+        c1.call("stop_server");
+        std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    });
+
+    s.run();
+    handle.get();
+
+    EXPECT_EQ(c1.get_connection_state(),
+              client::connection_state::disconnected);
+    EXPECT_EQ(c2.get_connection_state(),
+              client::connection_state::disconnected);
+}