Add buffer packer

This commit is contained in:
Dolan Miu
2018-07-01 02:16:11 +01:00
parent 4b06baab3f
commit ded155a6af
4 changed files with 68 additions and 0 deletions

View File

@ -0,0 +1,28 @@
import { Writable } from "stream";
export class BufferStream extends Writable {
private data: Buffer[];
constructor() {
super();
this.data = [];
}
// tslint:disable-next-line:no-any
public _write(chunk: any, encoding: string, next: (err?: Error) => void): void {
this.data.push(Buffer.from(chunk));
next();
}
// tslint:disable-next-line:ban-types
public end(cb?: Function): void {
super.end(cb);
this.emit("close");
}
public get Buffer(): Buffer {
return Buffer.concat(this.data);
}
}