stream.py

stream.py copied to clipboard

There are small typos in: - doc/index.rst - stream.py Fixes: - Should read `represented` rather than `respresented`. - Should read `further` rather than `futher`. - Should read `first` rather than...

timgates42

If you are processing a stream that has a chance of failure, each workers in your ThreadPool/ProcessPool will eventually hit a failure case and die. Once all of the workers...

movermeyer

PCollector cannot collect items from ProcessPool

1

[The documentation](http://www.trinhhaianh.com/stream.py/#mergers) states: > PCollectors can collect from ForkedFeeder‘s or ProcessPool‘s (via system pipes) > ... > class PCollector([waittime=0.1]): Collect items from many ForkedFeeder‘s or ProcessPool‘s. However, when you [try...

movermeyer

Updates

5

This library is awesome and deserves to be used in the python3 ecosystem. Tests pass with these updates (at least on my python 3.10.12 version).

frobnitzem