Kea 2016 rx breakout

rx-fun.js

var Rx = require('rx')

var slowSource = Rx.Observable.create(function(observer) {
 var count = 0
 setInterval(function() {
  observer.onNext(count++) 
 }, 1000) 
})


var fastSource = Rx.Observable.create(function(observer) {
 var count = 0
 setInterval(function() {
  observer.onNext(count++) 
 }, 300) 
})

var merged = Rx.Observable.merge(fastSource, slowSource)

merged.subscribe(
  function(x) {
    console.log('next even', x);
  }, 
  function(err) {
    console.log('error');
  }, 
  function() {
    console.log('done');
  })