29 lines
429 B
JavaScript
29 lines
429 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);
|
||
|
|
}
|
||
|
|
};
|