Rx.Observable - bindCallback (as opposed to bindNodeCallback)

bind-callback.js

const register = function (cb) {
  
  let m = 0;
  
  setInterval(() => {
    
    m++;
    
    cb(m, (err, v) => {
      console.log('we got:', err, v);
    });
    
  }, 500);
  
  return cb;  // return the anonymous function so it can be referenced by rxjs
  
};


const {bindCallback} = require('rxjs');
const obs = bindCallback(register((v, cb) => {
  
  setTimeout(() => {
    cb(null, v + 'sooo');  // cb is not a function .... wutttt :(
  }, 200);
  
}));


const subscription = obs().subscribe(v => {
  console.log('on next:', v);
}, e => {
   console.log('on error:', e);
});