rx.js snippets

counter.js

import { Observable } from 'rx'
const { fromEvent } = Observable

const $app = document.querySelector('#app')
$app.innerText = 'app'

const one = () => 1
const sum = (x, y) => x + y

fromEvent($app, 'click')
  .map(one)
  .startWith(100)
  .scan(sum)
  .subscribe(log)

github-users.js

import { Observable } from 'rx'
import { get } from 'axios'
const { just, fromPromise } = Observable

const log = console.log.bind(console)
const $app = document.querySelector('#app')
$app.innerText = 'app'

const url = 'http://api.github.com/users'
const mapUrl = () => url
const getUrl = url => fromPromise(get(url))

fromEvent($app, 'click')
  .startWith('startup click')
  .map(mapUrl)
  .flatMap(getUrl)
  .subscribe(log)