src/unpipe.js
function unpipe (callback, options) {
  check.assert.function(callback, 'Invalid callback argument')

  const jsonstream = new stream.PassThrough()

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

  return jsonstream
}
function unpipe (callback, options) {
  check.assert.function(callback, 'Invalid callback argument')

  const jsonstream = new stream.PassThrough()

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

  return jsonstream
}
function unpipe ( callback , options ) { check . assert . function ( callback , 'Invalid callback argument' ) const jsonstream = new stream . PassThrough ( ) parse ( jsonstream , Object . assign ( { } , options , { ndjson : false } ) ) . then ( data => callback ( null , data ) ) . catch ( error => callback ( error ) ) return jsonstream }
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.
Public function unpipe .