Fix threads not properly stopped on streaming tests
This commit is contained in:
parent
4f11c03b94
commit
172aa55186
|
@ -75,6 +75,8 @@ TEST(streaming, low_level_sending_strings) {
|
|||
|
||||
std::this_thread::sleep_for(2ms);
|
||||
ASSERT_GE(message_count, number_of_messages - 3u);
|
||||
|
||||
io.service.stop();
|
||||
}
|
||||
|
||||
TEST(streaming, low_level_unsubscribing) {
|
||||
|
@ -118,6 +120,8 @@ TEST(streaming, low_level_unsubscribing) {
|
|||
|
||||
ASSERT_GE(message_count, number_of_messages - 3u);
|
||||
}
|
||||
|
||||
io.service.stop();
|
||||
}
|
||||
|
||||
TEST(streaming, low_level_tcp_small_message) {
|
||||
|
|
Loading…
Reference in New Issue