1. module ndjson
   1. function ndjson (opts)
   2. function ndjson.parse (opts)
   3. function ndjson.serialize (opts)
   4. function ndjson.stringify (opts)
2. module ndjson.parse
   1. function ndjson.parse (opts)
   2. function ndjson.parse.serialize (opts)
   3. function ndjson.parse.stringify (opts)

module ndjson

function ndjson (opts)

• description and source-code

  function parse(opts) {
    opts = opts || {}
    opts.strict = opts.strict !== false
  
    function parseRow (row) {
      try {
        if (row) return JSON.parse(row)
      } catch (e) {
        if (opts.strict) {
          this.emit('error', new Error('Could not parse row ' + row.slice(0, 50) + '...'))
        }
      }
    }
  
    return split(parseRow, opts)
  }

• example usage

  n/a

function ndjson.parse (opts)

• description and source-code

  function parse(opts) {
    opts = opts || {}
    opts.strict = opts.strict !== false
  
    function parseRow (row) {
      try {
        if (row) return JSON.parse(row)
      } catch (e) {
        if (opts.strict) {
          this.emit('error', new Error('Could not parse row ' + row.slice(0, 50) + '...'))
        }
      }
    }
  
    return split(parseRow, opts)
  }

• example usage

  ...
    console.error('Usage: ndjson [input] <options>')
    process.exit(1)
  }
  
  if (first === '-') inputStream = process.stdin
  else inputStream = fs.createReadStream(first)
  
  var parse = ndjson.parse(args)
  var serializer = ndjson.serialize(args)
  
  inputStream.pipe(parse).pipe(serializer).pipe(process.stdout)
  ...

function ndjson.serialize (opts)

• description and source-code

  function serialize(opts) {
    return through.obj(opts, function(obj, enc, cb) {
      cb(null, stringify(obj) + EOL)
    })
  }

• example usage

  ...
    process.exit(1)
  }
  
  if (first === '-') inputStream = process.stdin
  else inputStream = fs.createReadStream(first)
  
  var parse = ndjson.parse(args)
  var serializer = ndjson.serialize(args)
  
  inputStream.pipe(parse).pipe(serializer).pipe(process.stdout)
  ...

function ndjson.stringify (opts)

• description and source-code

  function serialize(opts) {
    return through.obj(opts, function(obj, enc, cb) {
      cb(null, stringify(obj) + EOL)
    })
  }

• example usage

  ...
  fs.createReadStream('data.txt')
    .pipe(ndjson.parse())
    .on('data', function(obj) {
      // obj is a javascript object
    })
  ```
  
  #### ndjson.serialize() / ndjson.stringify()
  
  returns a transform stream that accepts json objects and emits newline delimited json
  
  example usage:
  
  ```js
  var serialize = ndjson.serialize()
  ...

module ndjson.parse

function ndjson.parse (opts)

• description and source-code

  function parse(opts) {
    opts = opts || {}
    opts.strict = opts.strict !== false
  
    function parseRow (row) {
      try {
        if (row) return JSON.parse(row)
      } catch (e) {
        if (opts.strict) {
          this.emit('error', new Error('Could not parse row ' + row.slice(0, 50) + '...'))
        }
      }
    }
  
    return split(parseRow, opts)
  }

• example usage

  ...
    console.error('Usage: ndjson [input] <options>')
    process.exit(1)
  }
  
  if (first === '-') inputStream = process.stdin
  else inputStream = fs.createReadStream(first)
  
  var parse = ndjson.parse(args)
  var serializer = ndjson.serialize(args)
  
  inputStream.pipe(parse).pipe(serializer).pipe(process.stdout)
  ...

function ndjson.parse.serialize (opts)

• description and source-code

  function serialize(opts) {
    return through.obj(opts, function(obj, enc, cb) {
      cb(null, stringify(obj) + EOL)
    })
  }

• example usage

  ...
    process.exit(1)
  }
  
  if (first === '-') inputStream = process.stdin
  else inputStream = fs.createReadStream(first)
  
  var parse = ndjson.parse(args)
  var serializer = ndjson.serialize(args)
  
  inputStream.pipe(parse).pipe(serializer).pipe(process.stdout)
  ...

function ndjson.parse.stringify (opts)

• description and source-code

  function serialize(opts) {
    return through.obj(opts, function(obj, enc, cb) {
      cb(null, stringify(obj) + EOL)
    })
  }

• example usage

  ...
  fs.createReadStream('data.txt')
    .pipe(ndjson.parse())
    .on('data', function(obj) {
      // obj is a javascript object
    })
  ```
  
  #### ndjson.serialize() / ndjson.stringify()
  
  returns a transform stream that accepts json objects and emits newline delimited json
  
  example usage:
  
  ```js
  var serialize = ndjson.serialize()
  ...