Skip to content
This repository was archived by the owner on Jul 21, 2020. It is now read-only.

Commit 46ab240

Browse files
committed
[Chat/Constellation] Fixed a few websocket close issues
1 parent 26ab72e commit 46ab240

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

src/main/java/com/mixer/api/resource/chat/ws/MixerChatConnection.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -138,6 +138,7 @@ public void onMessage(String s) {
138138
}
139139

140140
@Override public void onClose(int i, String s, boolean b) {
141+
this.close(i);
141142
this.producer.notifyClose(i, s, b);
142143
}
143144

src/main/java/com/mixer/api/resource/constellation/ws/MixerConstellationConnection.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,7 @@ public void onMessage(String s) {
135135
JsonObject json = new JsonObject();
136136
json.add("data", obj);
137137
this.dispatchEvent(this.mixer.gson.fromJson(json, type));
138+
this.close(i);
138139
this.producer.notifyClose(i, s, b);
139140
}
140141

0 commit comments

Comments
 (0)