Skip to content

Instantly share code, notes, and snippets.

@santaklouse
Created September 20, 2023 18:39
Show Gist options
  • Save santaklouse/b916a1edde0bc0bd0b0721367d01f5de to your computer and use it in GitHub Desktop.
Save santaklouse/b916a1edde0bc0bd0b0721367d01f5de to your computer and use it in GitHub Desktop.
import { pipeline } from 'node:stream/promises'
import { Writable } from 'node:stream'
import fs from "fs";
import StreamObject from "stream-json/streamers/StreamObject.js";
return new Promise(async (resolve) =>
await pipeline(
fs.createReadStream(this.cacheFileFullPath(filename)),
StreamArray.withParser(),
new Writable({
objectMode: true,
write: (data, _, done) => {
resolve(data.value);
done(null, data.value)
},
})
)
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment