11 lines
273 B
JavaScript
11 lines
273 B
JavaScript
import { Writable } from "stream";
|
|
export class Collector extends Writable {
|
|
constructor() {
|
|
super(...arguments);
|
|
this.bufferedBytes = [];
|
|
}
|
|
_write(chunk, encoding, callback) {
|
|
this.bufferedBytes.push(chunk);
|
|
callback();
|
|
}
|
|
}
|