@annexwu-packages/simple-stream-utils v0.0.3

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

getCRC64FromBuffer

Calculate the crc64 value of buffer

const { getCRC64FromBuffer } = require('@annexwu-packages/simple-stream-utils');
const buffer = Buffer.from('read stream example', 'utf8');
const crc64 = getCRC64FromBuffer(buffer);