fix (#42)
This commit is contained in:
parent
8ab9b92f60
commit
84dffdf510
|
@ -156,11 +156,11 @@ export default class Stream extends EventEmitter<StreamEvents> {
|
||||||
}
|
}
|
||||||
|
|
||||||
for (const c of connections) {
|
for (const c of connections) {
|
||||||
c.emit(body.type, Object.freeze(body.body));
|
c.emit(body.type, body.body);
|
||||||
c.inCount++;
|
c.inCount++;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
this.emit(type, Object.freeze(body));
|
this.emit(type, body);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue