streamrx
v0.0.3
Published
Implementing RxJs with Streams API
Downloads
6
Readme
streamrx
Implementing RxJs with Streams API
install
npm
npm i streamrx
yarn
yarn add streamrx
pnpm
pnpm i streamrx
usage
import { interval, takeWhile, map } from 'streamrx';
interval(1000)
.pipeThrough(map(x => 10 - x))
.pipeThrough(takeWhile(x => x > 0))
.pipeTo(new WritableStream({
write(chunk) {
console.log(chunk);
}
}));