Rx Webstreams

WARNING: HIGHLY ALPHA RIGHT NOW!

A deno package by @codemonument with RxJS like functionality, but for webstreams. It provides a lot of predefined sources, targets and especially transforms!

Note, that the api is inspired by RxJS, but not related in any other way. This package is especially not based on RxJS!

Parts

• Sources: Predefined Readable Streams, like fileSource(), timerSource(), and more
• Transforms: Predefined Transport Streams, like map(), reduce(), and more
• Targets: Predefined Writable Streams, like fileTarget(), urlTarget(), and more

Usage

ToDo (Look at the tests in the meantime! They give you a very good idea of how to use those!)

Sources

• timerSource() - implemented ✅
• fileSource() - planned

Transforms

• map() - planned
• reduce() - planned

Targets

• fileTarget() - planned
• urlTarget() - in consideration

Useful Links

• web.dev - Guide to Webstreams
• MDN - General Section on Webstreams
• MDN - Webstreams API Concepts
• MDN - Using Readable Streams
• MDN - Using Readable Byte Streams
• MDN - Using Writable Streams