whatwg-stream-wrapper.js

'use strict'

const Readable = require('stream').Readable

class StreamWrapper extends Readable {
  constructor (stream) {
    super()

    this._read = () => {
      stream.read().then((chunk) => {
        if (chunk.done) {
          this.push(null)
        } else {
          this.push(new Buffer(chunk.value))
        }
      }).catch((err) => {
        this.emit('error', err)
      })
    }
  }
}

module.exports = StreamWrapper