@annexwu-packages/multiple-stream-utils

@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);