ts-stream

Type-safe object streams with seamless support for backpressure, ending, and error handling

web-streams-extensions

A comprehensive collection of helper methods for WebStreams with built-in backpressure support, inspired by ReactiveExtensions