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 |
|