| 1 | const Stream = require('stream');
|
| 2 |
|
| 3 | class ResponseStream extends Stream.Readable {
|
| 4 | constructor() {
|
| 5 | super();
|
| 6 | this.statusCode = 200;
|
| 7 | this.status = 'OK';
|
| 8 | }
|
| 9 |
|
| 10 | error(code, message) {
|
| 11 | this.statusCode = code;
|
| 12 | this.status = message;
|
| 13 | return this;
|
| 14 | }
|
| 15 |
|
| 16 | on(event, handler) {
|
| 17 | if (['end', 'open'].includes(event)) handler();
|
| 18 | }
|
| 19 |
|
| 20 | _read() {} // eslint-disable-line no-empty-function
|
| 21 | }
|
| 22 |
|
| 23 | module.exports = ResponseStream;
|