Hi I built this little stream processing library so I could write things like;<p><pre><code> const stats = await pipe(
Nodes.scan({ fields: true }),
map(generateStats),
tap(() => count++),
reduce(mergeGraphStats, {})
)
</code></pre>
and have <i>generateStats</i> and <i>mergeGraphStats</i> be async functions and not have to worry about error handling and pushing more than one object at a time in a read stream. We use it to process billions of events and objects a day. It makes nodejs streams fun to use.<p>Hope you find it as useful as we do.