@annexwu-packages/simple-stream-utils

@annexwu-packages/simple-stream-utils

Usage

const { Readable } = require('stream');
const { TrashWriteStream } = require('@annexwu-packages/simple-stream-utils');

Readable.from(['read stream example']).pipe(new TrashWriteStream());

API

TrashWriteStream

Create a writable stream which consume all data from upstream

const { TrashWriteStream } = require('@annexwu-packages/simple-stream-utils');

readStream.pipe(new TrashWriteStream());

CRC64TransformStream

Create a transform stream which calculate the crc64 value of data pass through

const { CRC64TransformStream } = require('@annexwu-packages/simple-stream-utils');
const transformStream = new CRC64TransformStream();
transformStream.on('hash', hash => console.log(hash));
readStream.pipe(transformStream).pipe(writeStream);