This commit is contained in:
Naoyuki Kanezawa
2015-08-09 05:59:59 +09:00
parent 3bcf06c53e
commit 649f53925d

View File

@@ -57,7 +57,8 @@ public class WebSocket extends Transport {
} }
} }
final Request request = builder.build(); final Request request = builder.build();
(wsCall = WebSocketCall.create(client, request)).enqueue(new WebSocketListener() { wsCall = WebSocketCall.create(client, request);
wsCall.enqueue(new WebSocketListener() {
@Override @Override
public void onOpen(com.squareup.okhttp.ws.WebSocket webSocket, Response response) { public void onOpen(com.squareup.okhttp.ws.WebSocket webSocket, Response response) {
ws = webSocket; ws = webSocket;
@@ -175,7 +176,6 @@ public class WebSocket extends Transport {
protected void doClose() { protected void doClose() {
if (wsCall != null) { if (wsCall != null) {
wsCall.cancel(); wsCall.cancel();
wsCall = null;
} }
if (ws != null) { if (ws != null) {
try { try {
@@ -185,7 +185,6 @@ public class WebSocket extends Transport {
} catch (IllegalStateException e) { } catch (IllegalStateException e) {
// websocket already closed // websocket already closed
} }
ws = null;
} }
} }