// Copyright 2015 The Vanadium Authors. All rights reserved. | |
// Use of this source code is governed by a BSD-style | |
// license that can be found in the LICENSE file. | |
var through2 = require('through2'); | |
module.exports = create; | |
function create() { | |
return through2.obj(write); | |
} | |
function write(buffer, enc, callback) { | |
if (buffer.length === 0) { | |
return callback(); | |
} | |
var json; | |
var err; | |
try { | |
json = JSON.parse(buffer); | |
} catch (err) { | |
err.data = buffer; | |
} | |
callback(err, json); | |
} |