Configure Redis pubsub to skip subscription messages

src/socketio/asyncio_redis_manager.py

@@ -51,7 +51,7 @@ class AsyncRedisManager(AsyncPubSubManager):  # pragma: no cover
     def _redis_connect(self):
         self.redis = aioredis.Redis.from_url(self.redis_url,
                                              **self.redis_options)
-        self.pubsub = self.redis.pubsub()
+        self.pubsub = self.redis.pubsub(ignore_subscribe_messages=True)
 
     async def _publish(self, data):
         retry = True

src/socketio/redis_manager.py

@@ -70,7 +70,7 @@ class RedisManager(PubSubManager):  # pragma: no cover
     def _redis_connect(self):
         self.redis = redis.Redis.from_url(self.redis_url,
                                           **self.redis_options)
-        self.pubsub = self.redis.pubsub()
+        self.pubsub = self.redis.pubsub(ignore_subscribe_messages=True)
 
     def _publish(self, data):
         retry = True