SNOFLOW

Examples

$3

``ts
await snoflow([1, 2, 3])
.buffer(2)
.debounce(100)
.filter()
.map((n) => [String(n)])
.flat()
.flatMap((n) => [String(n)])
.tees((s) => s.pipeTo(nils()))
.limit(1)
.map(() => 1)
.peek(() => {})
.reduce(0, (a, b) => a + b)
.skip(1)
.tail(1)
.throttle(100)
.done()
`

$3

`ts
await new ReadableStream({
start:(ctrl)=>{
[1, 2, 3].map(x=> ctrl.enqueue(x))
}
})
.pipeThrough(buffers(2))
.pipeThrough(debounces(100))
.pipeThrough(filters())
.pipeThrough(maps((n) => [String(n)]))
.pipeThrough(flats())
.pipeThrough(flatMaps((n) => [String(n)]))
.pipeThrough(teess((s) => s.pipeTo(nils())))
.pipeThrough(limits(1))
.pipeThrough(maps(() => 1))
.pipeThrough(peeks(() => {}))
.pipeThrough(reduces(0, (a, b) => a + b))
.pipeThrough(skips(1))
.pipeThrough(tails(1))
.pipeThrough(throttles(100))
.pipeTo(nils())

``