bufferCount =
(stream, n) =>
stream
.scan( (acc, x) => acc.length < n ? [...acc, x] : [x], [] )
.filter( arr => arr.length === 3)
bufferCount( obs.range(1,10), 3).view({size:40})
bufferCount2 =
(stream, n) =>
stream
.scan( (acc, x) => acc.length < n ? [...acc, x] : [x], [] )
.materialize()
.scan( (acc, event) =>
event.kind === 'C' ?
({event: acc.event, keep: acc.event.value.length > 0 && acc.event.value.length < n}) :
({event: event, keep: event.value.length === n}), {event:{}} )
.filter( x => x.keep )
.map( x => x.event.value )
bufferCount2( obs.range(1,10), 3).view({size:40})
obs.range(1,10)
.scan( (acc, x) => ({ window: acc.i % 3 == 0 ? new rx.ReplaySubject() : (acc.window.next(x), acc.window), i: acc.i+1}), { i: 0 })
.pluck('window')
.distinctUntilChanged()
.values()
bufferCount3 =
(stream, n) =>
stream
.scan( (acc, x) => acc.length < n ? (acc.push(x), acc) : [x], [] )
.distinctUntilChanged()
bufferCount3(obs.range(1,10), 3).values()
seconds$ = obs.interval(1000)
value
sub = {
var s = seconds$.subscribe(set);
invalidation.then(() => s.unsubscribe());
return s;
}
setTimeout( () => sub.unsubscribe(), 10000 )
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
