| 1234567891011121314151617181920212223 |
- 'use strict';
- const stream = require('stream');
- class BaseStream extends stream.Readable {
- addEntry(/* entry, opts */) {
- throw new Error('.addEntry not implemented in sub class!');
- }
- _read() {}
- emit(event, data) {
- if (event === 'error') {
- const error = data;
- if (error.name === 'Error') {
- error.name = this.constructor.name + 'Error';
- }
- }
- super.emit(event, data);
- }
- }
- module.exports = BaseStream;
|