Provides a composable API for working with async iterables through pipes, tasks, and sinks.
Warning
All streams automatically filter out undefined values. This filtering occurs at stream creation
and when tasks are chained together, ensuring that undefined never flows through your pipeline.
undefined values are removed from all streams
Other falsy values (null, 0, false, "") are preserved
Custom tasks yielding undefined have those values automatically filtered
This behavior is centralized in the items() function, which is used internally for all stream creation
Remarks
The library is designed to be extensible. You can create custom feeds, tasks, and sinks
to suit your specific needs by following the patterns demonstrated in each module.
Asynchronous stream processing utilities.
Provides a composable API for working with async iterables through pipes, tasks, and sinks.
All streams automatically filter out
undefinedvalues. This filtering occurs at stream creation and when tasks are chained together, ensuring thatundefinednever flows through your pipeline.undefinedvalues are removed from all streamsnull,0,false,"") are preservedundefinedhave those values automatically filtereditems()function, which is used internally for all stream creationRemarks
The library is designed to be extensible. You can create custom feeds, tasks, and sinks to suit your specific needs by following the patterns demonstrated in each module.