summaryrefslogtreecommitdiff
path: root/src/server/api/stream
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-10-08 00:58:10 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-10-08 00:58:10 +0900
commit305915611e98094eea832d0441f1d0990096f8ab (patch)
tree7b1089c60c41e6ebf6b9e77fdde68f8ecfe89c76 /src/server/api/stream
parentfix(package): update @types/debug to version 0.0.31 (#2822) (diff)
downloadmisskey-305915611e98094eea832d0441f1d0990096f8ab.tar.gz
misskey-305915611e98094eea832d0441f1d0990096f8ab.tar.bz2
misskey-305915611e98094eea832d0441f1d0990096f8ab.zip
Fix bug
Diffstat (limited to 'src/server/api/stream')
-rw-r--r--src/server/api/stream/index.ts2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/server/api/stream/index.ts b/src/server/api/stream/index.ts
index 743d77b2a3..ef6397fcd9 100644
--- a/src/server/api/stream/index.ts
+++ b/src/server/api/stream/index.ts
@@ -24,6 +24,7 @@ export default class Connection {
public subscriber: Xev;
private channels: Channel[] = [];
private subscribingNotes: any = {};
+ public sendMessageToWsOverride: any = null; // 後方互換性のため
constructor(
wsConnection: websocket.connection,
@@ -164,6 +165,7 @@ export default class Connection {
*/
@autobind
public sendMessageToWs(type: string, payload: any) {
+ if (this.sendMessageToWsOverride) return this.sendMessageToWsOverride(type, payload); // 後方互換性のため
this.wsConnection.send(JSON.stringify({
type: type,
body: payload