Fix pubsub RECONNECT messages

Fix pubsub RECONNECT messages

Author: chillymosh

docs/changelog.rst

@@ -34,6 +34,10 @@ Master
             - :func:`~twitchio.ext.eventsub.EventSubClient.subscribe_channel_shoutout_create`
             - :func:`~twitchio.ext.eventsub.EventSubClient.subscribe_channel_shoutout_receive`
 
+- ext.pubsub
+    - Bug fixes
+        - Fix forced RECONNECT messages
+
 2.5.0
 ======
 - TwitchIO

twitchio/ext/pubsub/websocket.py

@@ -203,3 +203,7 @@ async def handle_response(self, message: dict):
         elif message["nonce"]:
             logger.debug(f"Received OK response for nonce {message['nonce']}")
             self.client.run_event("pubsub_nonce", message)
+
+    async def handle_reconnect(self, message: dict):
+        logger.warning("Received RECONNECT response from pubsub edge. Reconnecting")
+        await asyncio.shield(self.reconnect())