You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
39 lines
1.1 KiB
39 lines
1.1 KiB
import {createReadStream} from "fs";
|
|
import {createInterface} from "readline";
|
|
|
|
export default function(file, newlineDelimited, callback) {
|
|
var index = -1,
|
|
input = file === "-" ? process.stdin : createReadStream(file);
|
|
|
|
function readObject() {
|
|
return new Promise(function(resolve, reject) {
|
|
var data = [];
|
|
input
|
|
.on("data", function(d) { data.push(d); })
|
|
.on("end", function() { resolve(JSON.parse(Buffer.concat(data))); })
|
|
.on("error", reject);
|
|
});
|
|
}
|
|
|
|
function readNewlineDelimitedObjects() {
|
|
return new Promise(function(resolve, reject) {
|
|
var queue = Promise.resolve();
|
|
createInterface({
|
|
input: input,
|
|
output: null
|
|
}).on("line", function(line) {
|
|
queue = queue.then(function() { return callbackObject(JSON.parse(line)); });
|
|
}).on("close", function() {
|
|
queue.then(function() { resolve(); }, reject);
|
|
}).on("error", reject);
|
|
});
|
|
}
|
|
|
|
function callbackObject(object) {
|
|
return callback(object, ++index);
|
|
}
|
|
|
|
return newlineDelimited
|
|
? readNewlineDelimitedObjects()
|
|
: readObject().then(callbackObject);
|
|
}
|
|
|