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

Implement call operator #43

Closed vxgmichel closed 5 years ago

vxgmichel commented 5 years ago

Also fixes the issue of interrupting a map:

await (xs | pipe.map(some_afunc) | pipe.take(10) | pipe.list())
# Might produce:
# sys:1: RuntimeWarning: coroutine 'some_afunc' was never awaited
# RuntimeWarning: Enable tracemalloc to get the object allocation traceback
coveralls commented 5 years ago

Coverage Status

Coverage remained the same at 100.0% when pulling 58425318c496dfcc070ef9117182bed5abb83053 on call-operator into 6845b4e66b5404891d7ec681438af243be0efd30 on master.