missing required package

Author: Sebastian Molenda

pubnub/event_engine/effects.py

@@ -218,12 +218,15 @@ async def delayed_reconnect_async(self, delay, attempt):
         elif response.status.error:
             self.logger.warning(f'Reconnect failed: {response.status.error_data.__dict__}')
             self.failure(response.status.error_data, attempt, self.get_timetoken())
-        else:
+        elif 't' in response.result:
             cursor = response.result['t']
             timetoken = int(self.invocation.timetoken) if self.invocation.timetoken else cursor['t']
             region = cursor['r']
             messages = response.result['m']
             self.success(timetoken=timetoken, region=region, messages=messages)
+        else:
+            self.logger.warning(f'Reconnect failed: Invalid response {str(response)}')
+            self.failure(str(response), attempt, self.get_timetoken())
 
     def stop(self):
         self.logger.debug(f'stop called on {self.__class__.__name__}')

requirements-dev.txt

@@ -5,6 +5,7 @@ flake8
 pytest
 pytest-asyncio
 httpx
+h2
 requests
 aiohttp
 cbor2

tests/acceptance/subscribe/steps/then_steps.py

@@ -125,7 +125,7 @@ async def step_impl(ctx):
 @async_run_until_complete
 async def step_impl(context, channel1, channel2):
     context.pubnub.unsubscribe().channels([channel1, channel2]).execute()
-    await asyncio.sleep(0.5)
+    await asyncio.sleep(3)
 
 
 @then(u'I don\'t observe any Events and Invocations of the Presence EE')