search

vxgmichel / aiostream

Generator-based operators for asynchronous iteration
http://aiostream.readthedocs.io
GNU General Public License v3.0
800 stars 34 forks source link

action: support task_limit #85

Closed mpareja closed 1 year ago

mpareja commented 1 year ago

Is there any reason for not supporting the task_limit parameter on the action operator? The underlying implementation map allows it, so it would simply be a matter of forwarding the parameter.

vxgmichel commented 1 year ago

Hi @mpareja and thanks for the report

Is there any reason ...

Good catch, let's fix this: PR #86

vxgmichel commented 1 year ago

Merged, thanks!

mpareja commented 1 year ago

Okay, this is great - I'm already using it successfully, thanks!

One thing to note in 0.5.0: I'm using the new @pipable_operator but I was forced to import from:

from aiostream.core import pipable_operator
vxgmichel commented 1 year ago

Ooops how did I miss that, fixed in 0.5.1

Sorry for the inconvenience :)

mpareja commented 1 year ago

No worries @vxgmichel, I'm super happy to have your nice tight library, it's come in very useful!