base_write_stream.js 369 B

1234567891011121314151617
  1. 'use strict';
  2. const stream = require('stream');
  3. class UncompressBaseStream extends stream.Writable {
  4. emit(event, data) {
  5. if (event === 'error') {
  6. const error = data;
  7. if (error.name === 'Error') {
  8. error.name = this.constructor.name + 'Error';
  9. }
  10. }
  11. super.emit.apply(this, arguments);
  12. }
  13. }
  14. module.exports = UncompressBaseStream;