converting xstream to/from node streams

stream-to-xstream.js

const xs = require('xstream').default

module.exports = function fromStream (stream, flush = stream => {}) {
  return xs.create({
    start: listener => {
      stream.on('data', data => { listener.next(data) })
      stream.on('error', error => { listener.error(error) })
      stream.on('end', () => { listener.complete() })
    },
    stop: () => {
      flush(stream)
    }
  })
}

xstream-to-stream.js

const from = require('from2')

module.exports = function toStream (xstream) {
  let next
  let listening = false
  return from.obj(function (_, n) {
    next = n
    if (!listening) {
      xstream.addListener({
        next: x => { next(null, x) },
        error: e => { next(e, null) },
        complete: () => { next(null, null) },
      })
      listening = true
    }
  })
}