An abstract class to transform a readable stream to multiple writeable streams via pipe

Contents

• Installation
• Example usage

Installation

$ npm install @gluecode-it/readable-to-writeables-stream-processor

Example usage

import { ReadableToWriteablesSteamProcessor } from '@gluecode-it/readable-to-writeables-stream-processor';
import { Parse, Entry } from 'unzipper';
import { Writable } from 'stream';

export class ReadableStreamUnzipProcessor extends ReadableToWriteablesSteamProcessor {
  parseStream(getWriteableStreamCallback: (filePath: string) => Writable) {
    const stream = Parse();
    stream.on('entry', (entry: Entry) => {
      getWriteableStreamCallback(entry.props.path);
    });
    return stream;
  }
}

See also

• @gluecode-it/readable-stream-unzip-processor