| 1 | ;
|
| 2 |
|
| 3 | const { KellnerTransform } = require('../streams');
|
| 4 |
|
| 5 | module.exports = class KellnerRouter extends KellnerTransform {
|
| 6 | constructor(app, route, dest) {
|
| 7 | super(app);
|
| 8 | this.route = route;
|
| 9 | this.dest = dest;
|
| 10 | }
|
| 11 |
|
| 12 | _transform(message, encoding, next) {
|
| 13 | if (message[this.app.symbols.kellnerRoute] === this.route)
|
| 14 | this.dest.write(message);
|
| 15 | next(null, message);
|
| 16 | }
|
| 17 | };
|
| 18 |
|