begin standardizing our method of streaming lines from files

This commit is contained in:
ansuz
2020-03-04 11:38:07 -05:00
parent 35eca2c5d2
commit 32d769447a
4 changed files with 26 additions and 37 deletions

View File

@@ -59,7 +59,7 @@ const mkOffsetCounter = () => {
// that this function has a lower memory profile than our classic method
// of reading logs line by line.
// it also allows the handler to abort reading at any time
Stream.readFileBin = (env, stream, msgHandler, cb) => {
Stream.readFileBin = (stream, msgHandler, cb) => {
//const stream = Fs.createReadStream(path, { start: start });
let keepReading = true;
Pull(