info[0]
import {rx, obs, spy} from "@lbovet/rx-tools"
rx
rx.Observable === obs
obs.of(1, 2, 3, 4, 5)
value
obs.of(1,2,3,4).subscribe(set)
obs.of(1, 2, 3, 4, 5).values()
obs.of(1, 2, 3, 4, 5)
.filter(x => x % 2)
.map(x => 2*x)
.values()
obs.interval(1000).value()
obs.fromEvent(document, 'click').pluck('x').value()
obs.interval(1000).take(10).values()
obs.interval(1000).take(10).view()
obs
.interval(1000)
.map(util.colored)
.take(10)
.view()
obs.of(3).map(util.colored).value()
obs.of("cyan", "#f00", "hsl(108,80%,80%)").view({size:40})
obs
.fromPromise($.get(sample[0]))
.map(res => res.data.first_name)
.value()
get$ = (url) => obs.fromPromise($.get(url))
get$(sample[1])
.map(res => util.img(res.data.avatar))
.value()
info[1]
obs
.interval(1000)
.map( i => sample[i % 2] )
.do(spy(1).set)
.flatMap( get$ )
.map( res => res.data.first_name.length )
.map( util.colored )
.take(10)
.view()
spy(1).value()
obs.prototype.flatMap == obs.prototype.mergeMap
md`${sample[2]}`
get$(`${sample[2]}/users`).value()
allCommentersToLastPost =
(username) =>
obs.of(null)
.map(any => `${sample[2]}/users`)
.flatMap( get$ )
.flatMap( obs.from )
.filter( user => user.username == username )
.map( user => `${sample[2]}/posts?userId=${user.id}` )
.flatMap( get$ )
.flatMap( obs.from )
.last()
.map( post => `${sample[2]}/comments?postId=${post.id}` )
.flatMap( get$ )
.flatMap( obs.from )
.pluck('email')
allCommentersToLastPost('Samantha').values()
urls = sample[3]
urls.posts({id:4})
load =
computeUrl =>
obj => obs.of(obj)
.map(computeUrl)
.flatMap(get$)
.flatMap(obs.from)
firstCommentersToAllPosts =
(username) =>
obs.of(1)
.flatMap( load(urls.users) )
.filter( user => user.username == username )
.flatMap( load(urls.posts) )
.flatMap( util.compose(first, load(urls.comments)) )
.pluck('email')
info[3]
first = x => x.first()
firstCommentersToAllPosts('Samantha').values()
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.
