SocketCluster/writable-consumable-stream
View on GitHub ↗ ★ 25 JavaScript
An async stream which can be iterated over using a for-await-of loop.
3 mentions on Hacker News by 2 people: 0 stories, 3 comments · first 2021-01-25 · latest 2026-02-27
20082026
-
…and backpressure management since at least 2019. Here's the WritableConsumableStream module: https://github.com/SocketCluster/writable-consumable-stream SocketCluster solves the problem of maintaining message order with async processing.…
comment by socketcluster · 2026-02-27 · in A better streams API is possible for JavaScript -
…the ability to measure message backpressure and allows you to close or abruptly kill a stream: https://github.com/SocketCluster/writable-consumable-stream?... It has full test coverage and is a core part SocketCluster which has almost full…
comment by socketcluster · 2024-03-03 · in How to convert Node.js stream callback functions into an Async Iterator -
…I would recommend using awaitable streams like those used in https://socketcluster.io/ - Or https://github.com/SocketCluster/writable-consumable-stream for general purpose. The philosophy of SC and WritableConsumableStream is that the main…
comment by applepple · 2021-01-25 · in Node.js race conditions