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');
  } 
);

Was just playing with this and looking at RxJS v5…does this seem like a sensible translation (given there is no transduce operator):

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),
  R.of
);

const source = seq.flatMap(transducer);

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