transducer in es6 with ramda and rxjs

transducer-rxjs-ramda.js

const Rx = require('rx');                                                                                                               
const R  = require('ramda');

const seq = Rx.Observable.range(1, 10);

const isEven = (x) => x % 2 === 0;
const add1   = (x) => x + 1;

const transducer = R.compose(
  R.map(add1),
  R.filter(isEven)
);

const source = seq.transduce(transducer);

source.subscribe(
  /* onNext */ (i) => {
    console.log(i);
  },
  /* onError */ (err) => {
    console.error(err);
  },
  /* onComplete */ () => {
    console.log('All done');
  } 
);