Gecko [ gandhischool.edu.np ]

Name	Size	Permission
datastream.js	394 B	-rw-rw-rw-
error.js	479 B	-rw-rw-rw-
eventify.js	7 KB	-rw-rw-rw-
events.js	457 B	-rw-rw-rw-
index.js	346 B	-rw-rw-rw-
jsonstream.js	394 B	-rw-rw-rw-
match.js	6.69 KB	-rw-rw-rw-
memory.js	856 B	-rw-rw-rw-
parse.js	3.81 KB	-rw-rw-rw-
promise.js	88 B	-rw-rw-rw-
read.js	779 B	-rw-rw-rw-
stream.js	504 B	-rw-rw-rw-
streamify.js	5.91 KB	-rw-rw-rw-
stringify.js	1.74 KB	-rw-rw-rw-
unpipe.js	1.17 KB	-rw-rw-rw-
walk.js	14.15 KB	-rw-rw-rw-
write.js	1.65 KB	-rw-rw-rw-

Code Editor : unpipe.js

'use strict'

const stream = require('stream')
const check = require('check-types')
const parse = require('./parse')

module.exports = unpipe

/**
 * Public function `unpipe`.
 *
 * Returns a writeable stream that can be passed to stream.pipe, then parses JSON
 * data read from the stream. If there are no errors, the callback is invoked with
 * the result as the second argument. If errors occur, the first error is passed to
 * the callback as the first argument.
 *
 * @param callback:   Function that will be called after parsing is complete.
 *
 * @option reviver:   Transformation function, invoked depth-first.
 *
 * @option discard:   The number of characters to process before discarding them
 *                    to save memory. The default value is `1048576`.
 *
 * @option yieldRate: The number of data items to process per timeslice,
 *                    default is 16384.
 **/
function unpipe (callback, options) {
  check.assert.function(callback, 'Invalid callback argument')

const jsonstream = new stream.PassThrough()

parse(jsonstream, { ...options, ndjson: false })
    .then(data => callback(null, data))
    .catch(error => callback(error))

return jsonstream
}

${this.title}

Code Editor : unpipe.js