mario
mario copied to clipboard
Threaded apply
Currently, apply
builds a list of all the inputs instead of incrementally applying the function. This can result in large memory usage. Threading can be used to treat the AsyncIterable[T]
stream as a sync Iterable[T]
and apply the function without materializing a whole list. This would require users who want to build a list to explicitly create the list from the iterable.