cutcutcodec.core.opti.parallel.buffer.imap

cutcutcodec.core.opti.parallel.buffer.imap(func: callable, args: Iterable, maxsize: Integral = 0)

Like cutcutcodec.core.opti.parallel.starimap() with one argument.

Examples

>>> import time
>>> from cutcutcodec.core.opti.parallel.buffer import imap
>>> def foo(t):
...     time.sleep(t)
...     return t
...
>>> list(imap(foo, [1.0, 0.5, 0.0], maxsize=3))  # yield fastest first
[0.0, 0.5, 1.0]
>>>