|
@@ -190,6 +190,8 @@ public class AccompanyFragment extends BaseMVPFragment<FragmentAccompanyBinding,
|
|
|
};
|
|
|
private AccompanyPlayHelper mPlayHelper;
|
|
|
|
|
|
+ private boolean isInitWebSocket = true;
|
|
|
+
|
|
|
public static AccompanyFragment newInstance(String url) {
|
|
|
AccompanyFragment fragment = new AccompanyFragment();
|
|
|
Bundle args = new Bundle();
|
|
@@ -474,7 +476,8 @@ public class AccompanyFragment extends BaseMVPFragment<FragmentAccompanyBinding,
|
|
|
|
|
|
private void startWebSocketClient(JSONObject message) throws JSONException {
|
|
|
msg = message;
|
|
|
- if (webSocketClient == null) {
|
|
|
+ if (webSocketClient == null && isInitWebSocket) {
|
|
|
+ isInitWebSocket = false;//防止高频调用导致webSocket创建多次
|
|
|
Observable.create(new ObservableOnSubscribe<String>() {
|
|
|
@Override
|
|
|
public void subscribe(@NonNull ObservableEmitter<String> emitter) throws Exception {
|