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

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);
}