Ok so continuing to investigate, my question is summarize by the following:
#!/usr/bin/env python
import asyncio
import hiredis
from aioredis.util import encode_command
from aioredis.errors import ProtocolError, ReplyError
@asyncio.coroutine
def run_me():
reader, writer = yield from
safely close a connection in
case of CancelledError when waiting for the server answer.
Thank you all for your help on this.
Best regards,
Rémy
Le jeudi 9 avril 2015 15:54:22 UTC+2, Rémy Hubscher a écrit :
I tried to use reader.feed_data() for that but the next call to yield
from reader.read
Neat, thanks for the information.
Le lundi 6 avril 2015 18:04:20 UTC+2, rea...@gmail.com a écrit :
Hi,
I made a simple class called TimeTravelLoop for testing asyncio code that
has sleeps or waits inside of it.
You might find it useful. It could be found here:
I tried to use reader.feed_data() for that but the next call to yield from
reader.read() return the data feeded.
Le jeudi 9 avril 2015 15:33:29 UTC+2, Rémy Hubscher a écrit :
Ok so continuing to investigate, my question is summarize by the following:
#!/usr/bin/env python
import asyncio
Hello,
I am using aioredis on a BLPOP which is a blocking call on a redis
connection.
redis.blpop is a Future created here:
https://github.com/aio-libs/aioredis/blob/master/aioredis/connection.py#L154-L157
When using asyncio.wait_for(redis.blpop(channel), timeout=5) if the
timeout is raised
:03 UTC+2, Gustavo Carneiro a écrit :
On 8 April 2015 at 11:14, Rémy Hubscher hubsch...@gmail.com javascript:
wrote:
Hello,
I am using aioredis on a BLPOP which is a blocking call on a redis
connection.
redis.blpop is a Future created here:
https://github.com/aio-libs/aioredis/blob
