Anders E. Andersen
Anders E. Andersen
I have a few instances where I need to send the same items to multiple consumers. I have a working implementation for trio. ```python def broadcast(aiter): send_channels = [] lock...
First of all, I would not expect what I am doing to work. I don't think generators are supposed to work like the examples I am going to give. I...
I originally came up with the [listen](https://github.com/python-trio/triopg/blob/ccf44f9b40f0dc1945b8dcd152deaba11f195b28/triopg/_triopg.py#L131) helper for my personal code and I am very happy to see it implemented directly in triopg. Now in asyncpg v0.24 [add_listener](https://magicstack.github.io/asyncpg/current/api/index.html#asyncpg.connection.Connection) now...
I am playing smallstakes and freeroll tournaments on the bwin/partypoker network using the danskespil.dk client. This works fine most of the time, but sometimes it seems fpdb gets confused about...
The way broadcasting to taps and extensions works currently is not safe. It should support backpressure, but currently messages just pile up in a big queue, leading to possible memory...
This is a list of prior art for slurry-like frameworks of note, for documentation purposes. https://github.com/vxgmichel/aiostream https://github.com/erdewit/eventkit https://github.com/vodik/asyncitertools