writable-consumable-stream
writable-consumable-stream copied to clipboard
SocketCluster
An async stream which can be iterated over using a for-await-of loop.
I suggest to add `this.currentNode = undefined;` inside the Consumer's _destroy() method. Killed Consumer still holds the whole linked list of messages.
Hello, nice work on this lib. I like the linked list approach. I think I found a bug though, an implementation details that prevents doing "bulk reads" of the stream....
Metadata
Owner
Metadata
An async stream which can be iterated over using a for-await-of loop.