Most.js Node callback

import most, {
  create, of, from
}
from 'most';

function fromNodeCallback(fun) {
  return (...x) => create((add, end, error) => {
    x.push(handleNodeCB);
    fun.apply(null, x);
  });
}

function flatMapNode(fun) {
  return this.flatMap(x =>
    create((add, end, error) => {
      fun(x, handleNodeCB);
    })
  );
}

function handleNodeCB(add, end, error) {
  return (err, res) => {
    if (err) error(err);
    else {
      add(res);
      end();
    }
  };
}

module.exports = {
  node: fromNodeCallback,
  fromNodeCallback, // alias
  bindNodeCallback: fromNodeCallback, // alias
  flatMapNode,
  chainNode: flatMapNode,
  create,
  of,
  most,
  from
};