0.0.1 • Published 3 years ago
@annexwu-packages/multiple-stream-utils v0.0.1
@annexwu-packages/multiple-stream-utils
Usage
const { MultipleWriteStream } = require('@annexwu-packages/multiple-stream-utils');
const writeStream = new MultipleWriteStream({
nextStreamEvent: 'finish',
async getNextStream({ number = 0 } = {}) {
if(number >= 10) {
return;
}
return {
stream: fs.createWriteStream(`./${number}.md`),
streamSize: 1 * 1024 * 1024,
nextParams: {
number: number + 1,
},
}
},
});
readStream.pipe(writeStream);
API
MultipleWriteStream
Create a writable stream which combine by multiple writable stream
const { MultipleWriteStream } = require('@annexwu-packages/multiple-stream-utils');
const writeStream = new MultipleWriteStream({
nextStreamEvent: 'finish',
async getNextStream({ number = 0 } = {}) {
if(number >= 10) {
return;
}
return {
stream: fs.createWriteStream(`./${number}.md`),
streamSize: 1 * 1024 * 1024,
nextParams: {
number: number + 1,
},
}
},
});
readStream.pipe(writeStream);
0.0.1
3 years ago