ten$ = obs.range(1,10)
ten$.view()
ten$
.bufferCount(3)
.view({size:40})
tenSec$ = obs.interval(1000).take(10)
tenSec$.view({size:40})
tenSec$.buffer(obs.interval(2000)).view({size:40})
tenSec$.windowCount(3).flatMap(x => x.sum()).view()
tenSec$.window(obs.interval(3000)).flatMap(x => x.min()).view()
obs.of("hello", "world", "foo").scan( (acc, word) => acc += word.length, 0 ).view()
obs.interval(1000).take(10).map(util.random)
.scan( (acc, x) => ({ prev: x, color: acc.prev > x ? "white" : "black"}), {prev:0})
.pluck('color')
.view()
avg = arr => arr.length ? arr.reduce( (a,b) => a+b, 0)/arr.length : 0
windowShift = (arr, x, length) => [...arr, x].slice(-length)
ten$
.scan( (acc, x) => ({arr: windowShift(acc.arr, x, 4), avg: avg(acc.arr) }), {arr:[]})
.pluck('avg')
.view({size: 30})
validate = x => { if(x == 5) throw "ouch" }
validated$ = ten$.do(validate)
validated$.view()
validated$.catch(x => obs.of(10)).view()
validated$.retry(2).view()
ten$.flatMap( x => obs.of(x).do(validate).catch(x => obs.empty()) ).view()
ten$.flatMap( x => obs.of(x).do(console.log).do(validate).retry(2) ).view()
obs.never().view()
obs.empty().view()
obs.of(1).view()
obs.throw("ouch").view()
obs.concat( obs.of(1)).materialize().values()
obs.concat( obs.of(1), obs.throw("ouch")).materialize().values()
info[2]
wave$ = (length) => obs.range(1,36).map( x => Math.round( 128 * (1 + Math.sin(x/length)) ) )
wave$(10).map(x => `rgb(${x},${x},${x})`).view()
red$ = wave$(2)
green$ = wave$(3)
blue$ = wave$(5)
obs.zip(red$, green$, blue$, (x,y,z) => `rgb(${x},${y},${z})`).view()
colors = obs.zip(red$, green$, blue$, (x,y,z) => `rgb(${x},${y},${z})`).repeat()
clix$ = obs.fromEvent(document, 'click').pluck('x').timeout(30000)
clix$.view({size:40})
clix$.combineLatest(obs.interval(1000), (x,y) => x*y ).view({size:40})
clix$.withLatestFrom(obs.interval(1000), (x,y) => x*y ).view({size:40})
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.
