fixed: ConcurrentModificationException #115

realtybaron · realtybaron · commit 894b18062beb · 2016-07-05T14:16:53.000-05:00
diff --git a/src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java b/src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java
@@ -4,7 +4,6 @@
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.util.Collections;
-import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
@@ -56,7 +55,7 @@ public WebSocketConnection(
         this.factory = factory;
 
         for (final ConnectionState state : ConnectionState.values()) {
-            eventListeners.put(state, Collections.newSetFromMap(new HashMap<ConnectionEventListener, Boolean>()));
+            eventListeners.put(state, Collections.newSetFromMap(new ConcurrentHashMap<ConnectionEventListener, Boolean>()));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,6 @@`
`4`	`4`	`import java.net.URI;`
`5`	`5`	`import java.net.URISyntaxException;`
`6`	`6`	`import java.util.Collections;`
`7`		`-import java.util.HashMap;`
`8`	`7`	`import java.util.HashSet;`
`9`	`8`	`import java.util.Map;`
`10`	`9`	`import java.util.Set;`
`@@ -56,7 +55,7 @@ public WebSocketConnection(`
`56`	`55`	`this.factory = factory;`
`57`	`56`
`58`	`57`	`for (final ConnectionState state : ConnectionState.values()) {`
`59`		`- eventListeners.put(state, Collections.newSetFromMap(new HashMap<ConnectionEventListener, Boolean>()));`
	`58`	`+ eventListeners.put(state, Collections.newSetFromMap(new ConcurrentHashMap<ConnectionEventListener, Boolean>()));`
`60`	`59`	`}`
`61`	`60`	`}`
`62`	`61`