redis stream support

[bsergean]

Hi there, here are a bunch of questions around redis streams.

1. What is the plan for supporting redis stream? Wait until the feature is out of beta and redis 5 is released?
2. Should it be implemented like pubsub, or more like a normal set of commands.
3. Also I guess that it has to be supported in hiredis first ?
4. Would it be possible to try to implement it outside of redis stream in my own project, using monkey patching or something similar, until the support is really here (as is, how extensible aioredis is). That could be a bad idea?

Thanks for any thoughts !

[barrachri]

#299 is already inside master.

[barrachri]

Something that (I think) is missing is using xread with async for

messages = redis.xread(['test_stream'])

async for message in messages:
    pass

I guess we can use something like this:

https://github.com/aio-libs/aioredis/blob/ea948d0d7047db3315b4fbb9aa66e9ccc7e41522/aioredis/pubsub.py#L134

cc @adamcharnock

[adamcharnock]

Hey @barrachri, I think this would be a good feature. I don't have time to look into it right now, but I'd be happy to look over any pull request if you wish (although I have no authority to merge).

[barrachri]

Ok, thanks @adamcharnock!

[barrachri]

#472

[f0ff886f]

Some commands are still missing (XDEL) and (XTRIM), is it possible to get them in as well?

[ivarec]

Is this the main issue to track the development of XDEL and friends?

[curiouscod3]

@adamcharnock @ivarec @bsergean
I've added xdel and xtrim. Still needs some test in real world. Please try it.
It worked in my dev environment.