Blame view

code/finance_web/node_modules/bfj-node4/src/jsonstream.js 513 Bytes
a  
谢明辉 committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
'use strict'

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

util.inherits(JsonStream, Readable)

module.exports = JsonStream

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

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

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

  return Readable.call(this, { encoding: 'utf8' })
}