Skip to content

Commit 10a8d0e

Browse files
author
Sebastian Molenda
committed
Give time to propagate cg?
1 parent 1d86b43 commit 10a8d0e

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

tests/integrational/native_threads/test_subscribe.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,7 @@ def test_cg_subscribe_unsubscribe(self):
168168
result = cg_operation.await_result()
169169
assert isinstance(result, PNChannelGroupsAddChannelResult)
170170
cg_operation.reset()
171+
time.sleep(5)
171172

172173
pubnub.add_listener(callback_messages)
173174
pubnub.subscribe().channel_groups(gr).execute()
@@ -203,6 +204,8 @@ def test_subscribe_cg_publish_unsubscribe(self):
203204
.pn_async(non_subscribe_listener.callback)
204205
result = non_subscribe_listener.await_result_and_reset()
205206
assert isinstance(result, PNChannelGroupsAddChannelResult)
207+
non_subscribe_listener.reset()
208+
time.sleep(5)
206209

207210
pubnub.add_listener(callback_messages)
208211
pubnub.subscribe().channel_groups(gr).execute()
@@ -239,6 +242,7 @@ def test_subscribe_cg_join_leave(self):
239242
.sync()
240243

241244
assert isinstance(result.result, PNChannelGroupsAddChannelResult)
245+
time.sleep(5)
242246

243247
pubnub.config.uuid = helper.gen_channel("messenger")
244248
pubnub_listener.config.uuid = helper.gen_channel("listener")

0 commit comments

Comments
 (0)