slurry
slurry copied to clipboard
Python async data processing microframework
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...
Hi, I think slurry is good for my use case, but I cannot tell for sure, because there are not enough examples of using the various parts of the library...
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