From 326226c791b4983e73570ff93f8776b3d0a16d10 Mon Sep 17 00:00:00 2001 From: "larry.liu" Date: Thu, 20 Jul 2017 16:12:53 +0800 Subject: [PATCH] format code style format code style --- socketio/asyncio_redis_manager.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/socketio/asyncio_redis_manager.py b/socketio/asyncio_redis_manager.py index 630ff0e..826c49c 100644 --- a/socketio/asyncio_redis_manager.py +++ b/socketio/asyncio_redis_manager.py @@ -53,7 +53,7 @@ class AsyncRedisManager(AsyncPubSubManager): # pragma: no cover name = 'aioredis' def __init__(self, url='redis://localhost:6379/0', channel='socketio', - write_only=False,password=None): + write_only=False, password=None): if aioredis is None: raise RuntimeError('Redis package is not installed ' '(Run "pip install aioredis" in your ' @@ -61,19 +61,19 @@ class AsyncRedisManager(AsyncPubSubManager): # pragma: no cover self.host, self.port, self.db = _parse_redis_url(url) self.pub = None self.sub = None - self.password=password + self.password = password super().__init__(channel=channel, write_only=write_only) async def _publish(self, data): if self.pub is None: self.pub = await aioredis.create_redis((self.host, self.port), - db=self.db,password=self.password) + db=self.db, password=self.password) return await self.pub.publish(self.channel, pickle.dumps(data)) async def _listen(self): if self.sub is None: self.sub = await aioredis.create_redis((self.host, self.port), - db=self.db,password=self.password) + db=self.db, password=self.password) self.ch = (await self.sub.subscribe(self.channel))[0] while True: return await self.ch.get()