most-js-from-node-callback.js

import most from 'most';

const fromNodeCallback = (nodeCallback) => {
  return (...args) => {
    return most.create((add, end, error) => {
      return nodeCallback(...args, function cb(err, ...data) {
        // if data has more than one element, leave as array. Else, pass along that single value
        err ? error(err) : data.length > 1 ? add(data) : add(...data);
        end();
      });
    });
  };
};