xstream-buffer-time

pnpm install --save xstream-buffer-time

Emits buffered values over a set time-interval

usage

import xs from 'xstream'
import fromDiagram from 'xstream/extra/fromDiagram'
import bufferTime from 'xstream-buffer-time'
 
const stream = xs.periodic(50).take(8)
  .compose(bufferTime(200))
 
stream.addListener({
  next: i => console.log(i),
  error: err => console.error(err),
  complete: () => console.log('completed')
})

> starting
> [0, 1, 2]  (after 200 ms)
> [3, 4, 5, 6]  (after 400 ms)
> completed

License

MIT