stream.js 504 Bytes
'use strict'

const util = require('util')
const Readable = require('stream').Readable
const check = require('check-types')

util.inherits(BfjStream, Readable)

module.exports = BfjStream

function BfjStream (read, options) {
  if (check.not.instanceStrict(this, BfjStream)) {
    return new BfjStream(read)
  }

  check.assert.function(read, 'Invalid read implementation')

  this._read = function () { // eslint-disable-line no-underscore-dangle
    read()
  }

  return Readable.call(this, options)
}