Создаём первый readable stream и одним махом читаем первые 100 байт.
Создаём второй readable stream, указывая позицией начала чтения следующий байт.
const fs = require('fs');
const path = require('path');
const { pipeline } = require('stream');
(async () => {
const filepath = path.join(process.cwd(), 'large-file.json');
const stream1 = fs.createReadStream(
filepath,
{
start: 0,
end: 99,
highWaterMark: 100
}
);
const firstByte = await stream1[Symbol.asyncIterator]().next();
console.log(`${filepath} >>> ${firstByte.value}`);
const stream2 = fs.createReadStream(
filepath,
{
start: 100
}
);
await pipeline(stream2, cipher, write);
})();
UPD1:
Допустим stream приходит из сторонней библиотеки, как можно считать первые байты, а следующие данные как-то использовать/трансформировать?
const fs = require('fs');
const path = require('path');
(async () => {
const inputfile = path.join(__dirname, 'input.txt');
let iv;
const readStream = fs.createReadStream(inputfile);
readStream.once('readable', () => {
iv = readStream.read(6);
// may be your code here 1
// await pipeline(stream2, cipher, write);
});
// my example
for await (const chunk of readStream) {
console.log(`iv=${iv}, chunk=${chunk}`);
}
// may be your code here 2
})();
iv=123456, chunk=aaaa
iv=123456, chunk=aaaaaaaaaa
iv=123456, chunk=aaafffffff
iv=123456, chunk=gyrtgejeji
iv=123456, chunk=eejiwriuwe
iv=123456, chunk=iweuri'