From ec70018826024407c6af82a3b2fc03e8d4d5e6db Mon Sep 17 00:00:00 2001 From: Ziggy Jonsson Date: Tue, 13 Feb 2018 13:47:04 -0500 Subject: [PATCH] Expose a generic read method that can be extended to have more control over how the `readFn` is called, for example concurrency limits or combination of requests that are close in offsets --- lib/reader.js | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/lib/reader.js b/lib/reader.js index 43e78d9d..12d4c0da 100644 --- a/lib/reader.js +++ b/lib/reader.js @@ -201,11 +201,15 @@ class ParquetEnvelopeReader { } constructor(readFn, closeFn, fileSize) { - this.read = readFn; + this.readFn = readFn; this.close = closeFn; this.fileSize = fileSize; } + async read(offset, length) { + return this.readFn(offset, length); + } + async readHeader() { let buf = await this.read(0, PARQUET_MAGIC.length);