uptime$ = obs.interval(1000).publish()
uptime$.take(30).view()
//uptime$.connect()
uptime$.take(30).map(util.colored).view()
//sub = uptime$.connect()
//sub.unsubscribe()
util.random()
random$ = obs.of(1).repeat().map(util.random).do(spy(2).set).take(10).publish()
// without take, with publishReplay
spy(2).values()
random$.connect()
random$.take(20).view()
randomclix$ = clix$.zip(random$).pluck(1).shareReplay()
randomclix$.view()
randomclix$.view()
obs.zip( obs.interval(50)
.do(spy(2).set)
.take(50),
obs.interval(200)
.take(50) )
.value()
spy(2).value()
obs.interval(100).do(spy(3).set).take(100).concatMap( x => obs.of(x).delay(1000) ).view()
spy(3).value()
subject = new rx.Subject()
subject.view()
//subject.next(1)
//subject.error("ouch")
//subject.complete()
//obs.interval(1000).take(30).subscribe(subject)
subject.next("yellow")
//
viewof s1 = html`<input type=range>`
s1
s1sub = new rx.Subject()
s1sub.next(s1)
s1sub.view()
s1d = s1sub.debounceTime(200)
s1d.value()
s1d.view()
initial_value = "john"
viewof user = html`<input type=text value="${initial_value}">`
user$ = new rx.BehaviorSubject(initial_value)
user$.next(user)
user$.skip(1).debounceTime(200).distinctUntilChanged().map(s => html`Showing result for: <b>${s}`).value()
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.
