On streams, really prefer (async)generators over the streams api ... most of the Node streams support async generators with for-await syntax .. of course with ad-hoc stream-like that only support .pipe, it becomes a bigger issue.