Vincent Michel

I've been able to reproduce your issue using [this code](https://gist.github.com/vxgmichel/474d9ab0d13cccfdb352767d83aa0910). The problem is related to asyncio connecting to the broadcast address. Quoting [this post](http://developerweb.net/viewtopic.php?pid=22389#p22389): > Now, the main problem is...

Actually, `FIRST_COMPLETED` also returns if any future/coroutine raises an exception. In general, a future is considered completed when it gets its result or when an exception is raised. The following...

`ProcessPoolExecutor` uses `os.fork` (through `multiprocessing.popen_fork.Popen`). Does that mean it is unsafe to use `loop.run_in_executor` with a `ProcessPoolExecutor`? Or is it OK as long as the target doesn't mess with the...

As far as I understand, [Popen._launch](https://hg.python.org/cpython/file/default/Lib/multiprocessing/popen_fork.py#l64) runs `os.fork` then [Process._bootstrap](https://hg.python.org/cpython/file/default/Lib/multiprocessing/process.py#l228) in the child. `_bootstrap` does a bunch of things before [running the target](https://hg.python.org/cpython/file/default/Lib/multiprocessing/process.py#l88), but I don't see any `exec`.

> Perhaps the reason is that multiprocessing calls fork, and then, after fork, it executes the target code. When target is done, it exits the process. Yes that's exactly what...

> e.g. there could be an optional reduce argument (function taking two items and combining them) that would be invoked whenever an item arrives and there is one already pending....

> If you could provide a PR with a test case that fails using the current implementation, that would make it a bit easier to tweak the implementation to handling...

Hi @pbabics and thanks for your contribution! Funnily enough I explicitly removed this behavior in PR #70, because I thought that getting a clean state for each connection was the...

Hi @Lx, I finally took the time to type the code base: https://github.com/vxgmichel/aiostream/pull/84 All of the aiostream package is strictly checked, except for `aiostream.test_utils`. There are also a couple of...

Hi @javajawa > if you need an extra pair of hands I'm happy to help. Oh that's so nice thank you ! Would you mind trying #84 and see if...