| /dports/databases/py-aioredis/aioredis-1.3.1/tests/ |
| H A D | connection_test.py | 159 conn.execute_pubsub('subscribe', 'channel:1')
173 await conn.execute_pubsub('subscribe', 'channel:1')
191 await conn.execute_pubsub('subscribe', 'channel:1')
371 res = await sub.execute_pubsub('subscribe', 'chan:1')
377 res = await sub.execute_pubsub('subscribe', ch)
401 sub.execute_pubsub('subscribe', "chan:1", None)
403 sub.execute_pubsub('subscribe')
405 sub.execute_pubsub(
409 sub.execute_pubsub(
413 sub.execute_pubsub(
[all …]
|
| H A D | pubsub_receiver_test.py | 103 await sub.execute_pubsub('subscribe',
128 await sub.execute_pubsub('subscribe',
149 await sub.execute_pubsub('unsubscribe', 'channel:1')
161 await sub.execute_pubsub('unsubscribe', 'channel:3')
171 await sub.execute_pubsub('subscribe', mpsc.channel('channel:1'))
203 await sub.execute_pubsub('subscribe', mpsc.channel('channel:1'))
|
| H A D | pool_test.py | 439 res = await pool.execute_pubsub("subscribe", "channel:1")
445 res = await pool.execute_pubsub("subscribe", "channel:2")
455 fut2 = pool.execute_pubsub("subscribe", "channel:1")
457 fut4 = pool.execute_pubsub("subscribe", "channel:2")
|
| /dports/databases/py-aioredis/aioredis-1.3.1/examples/ |
| H A D | pool_pubsub.py | 23 await conn.execute_pubsub('subscribe', 'channel:1')
26 await conn.execute_pubsub('unsubscribe', 'channel:1')
31 await conn.execute_pubsub('subscribe', 'channel:1')
34 await conn.execute_pubsub('unsubscribe', 'channel:1')
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis/commands/ |
| H A D | pubsub.py | 31 conn.execute_pubsub(b'SUBSCRIBE', channel, *channels),
40 return conn.execute_pubsub(b'UNSUBSCRIBE', channel, *channels)
54 conn.execute_pubsub(b'PSUBSCRIBE', pattern, *patterns),
63 return conn.execute_pubsub(b'PUNSUBSCRIBE', pattern, *patterns)
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis/ |
| H A D | abc.py | 23 def execute_pubsub(self, command, *args, **kwargs): member in AbcConnection
|
| H A D | pool.py | 202 def execute_pubsub(self, command, *channels): member in ConnectionsPool
217 return conn.execute_pubsub(command, *channels)
275 return (await conn.execute_pubsub(command, *args, **kw))
|
| H A D | connection.py | 334 return self.execute_pubsub(command, *args)
357 def execute_pubsub(self, command, *channels): member in RedisConnection
|
| /dports/databases/py-aioredis/aioredis-1.3.1/docs/ |
| H A D | api_reference.rst | 168 .. method:: execute_pubsub(command, \*channels_or_patterns)
177 >>> await conn.execute_pubsub('subscribe', ch1)
195 >>> await conn.execute_pubsub('subscribe', 'A', 'B')
384 .. method:: execute_pubsub(command, \*channels)
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis/sentinel/ |
| H A D | pool.py | 228 await pool.execute_pubsub(
|
| /dports/databases/py-aioredis/aioredis-1.3.1/ |
| H A D | PKG-INFO | 569 * ``aioredis.ConnectionClosedError`` raised in ``execute_pubsub`` as well
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis.egg-info/ |
| H A D | PKG-INFO | 569 * ``aioredis.ConnectionClosedError`` raised in ``execute_pubsub`` as well
|