fromNodeCallback.js

import {Stream} from 'most'

const fromNodeCallBack = fn => (...args) => new Stream(new CallBackSource(fn, args))

class CallBackSource {
  constructor (fn, args) {
    this.fn = fn
    this.args = args
  }

  run (sink, scheduler) {
    const fn = this.fn
    const args = this.args

    try {
      fn(...args, (err, res) => {
          const t = scheduler.now()
          if (err) { sink.error(t, err) }
          sink.event(t, res)
          sink.end(t, res)
      })
    } catch (e) {
      sink.error(scheduler.now(), e)
    }

    return { dispose: () => {} }
  }
}