RxJS
Rx(ReactiveExtensions)のJS
ES6以降だとReadableStream, WritableStream, TransformStream(どちらも標準)で十分できそう