30 lines
430 B
JavaScript
30 lines
430 B
JavaScript
'use strict';
|
|
|
|
const Stream = require('stream');
|
|
|
|
const Payload = require('./payload');
|
|
|
|
|
|
const internals = {};
|
|
|
|
|
|
module.exports = internals.Tap = class extends Stream.Transform {
|
|
|
|
constructor() {
|
|
|
|
super();
|
|
this.buffers = [];
|
|
}
|
|
|
|
_transform(chunk, encoding, next) {
|
|
|
|
this.buffers.push(chunk);
|
|
next(null, chunk);
|
|
}
|
|
|
|
collect() {
|
|
|
|
return new Payload(this.buffers);
|
|
}
|
|
};
|