From 575fecc2d8cd7e733cc7d2ef0ead374ad7e0901c Mon Sep 17 00:00:00 2001 From: Naoyuki Kanezawa Date: Tue, 4 Nov 2014 01:16:28 +0900 Subject: [PATCH] add connected method --- .../java/com/github/nkzawa/socketio/client/Socket.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/github/nkzawa/socketio/client/Socket.java b/src/main/java/com/github/nkzawa/socketio/client/Socket.java index 2204db2..45a6546 100644 --- a/src/main/java/com/github/nkzawa/socketio/client/Socket.java +++ b/src/main/java/com/github/nkzawa/socketio/client/Socket.java @@ -68,8 +68,7 @@ public class Socket extends Emitter { put(EVENT_RECONNECTING, 1); }}; - private boolean connected; - private boolean disconnected = true; + private volatile boolean connected; private int ids; private String nsp; private Manager io; @@ -258,7 +257,6 @@ public class Socket extends Emitter { private void onclose(String reason) { logger.fine(String.format("close (%s)", reason)); this.connected = false; - this.disconnected = true; this.emit(EVENT_DISCONNECT, reason); } @@ -344,7 +342,6 @@ public class Socket extends Emitter { private void onconnect() { this.connected = true; - this.disconnected = false; this.emit(EVENT_CONNECT); this.emitBuffered(); } @@ -419,6 +416,10 @@ public class Socket extends Emitter { return io; } + public boolean connected() { + return connected; + } + private static Object[] toArray(JSONArray array) { int length = array.length(); Object[] data = new Object[length];