-
Notifications
You must be signed in to change notification settings - Fork 15
Open
Labels
Description
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.