RxJS Playground

A blank canvas to play / experiment with RxJS: https://github.com/Reactive-Extensions/RxJS

by mizobata

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.0.7/rx.all.js"></script>

JavaScript

console.clear();

const o1 = Rx.Observable.interval(1000).map(x => x).take(5)
// (1)
// o1.subscribe(x => console.log('stream1', x))

const o2 = Rx.Observable.interval(2000).map(y => y + 1).take(5)
// (1)
// o2.subscribe(y => console.log('stream2', y))

let counter = 0
const interval = setInterval(() => {
  console.log(counter++)
  if (counter === 10) clearInterval(interval)
}, 1000)

// (2)
// Rx.Observable.zip(o1, o2).subscribe(value => {
//   console.log('zip', value)
// })

// (3)
// Rx.Observable.combineLatest(o1, o2).subscribe(value => {
//   console.log('combineLatest', value)
// })

// (4)
// Rx.Observable.forkJoin(o1, o2).subscribe(value => {
//   console.log('forkJoin', value)
// })

// (5)
// o2.withLatestFrom(o1, (y, x) => y * x).subscribe(value => {
//   console.log('withLatestFrom', value))
// })