* Compresses data. * * @private
(data, encoding, callback)
| 321 | * @private |
| 322 | */ |
| 323 | private compress(data, encoding, callback) { |
| 324 | debug("compressing"); |
| 325 | |
| 326 | const buffers = []; |
| 327 | let nread = 0; |
| 328 | |
| 329 | compressionMethods[encoding](this.httpCompression) |
| 330 | .on("error", callback) |
| 331 | .on("data", function (chunk) { |
| 332 | buffers.push(chunk); |
| 333 | nread += chunk.length; |
| 334 | }) |
| 335 | .on("end", function () { |
| 336 | callback(null, Buffer.concat(buffers, nread)); |
| 337 | }) |
| 338 | .end(data); |
| 339 | } |
| 340 | |
| 341 | /** |
| 342 | * Closes the transport. |