From c8f69700f1e0142baf552d77f05f7deb3c680092 Mon Sep 17 00:00:00 2001
From: Jamie Patel <jamie@notespublication.com>
Date: Mon, 21 Mar 2016 14:25:43 +0000
Subject: [PATCH] make connection event listeners concurrent hashmap. Resolves
 #97

---
 .../client/connection/websocket/WebSocketConnection.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java b/src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java
index 4232ebb8..cebc4e00 100644
--- a/src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java
+++ b/src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java
@@ -7,6 +7,7 @@
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 
@@ -33,7 +34,7 @@ public class WebSocketConnection implements InternalConnection, WebSocketListene
 
     private final Factory factory;
     private final ActivityTimer activityTimer;
-    private final Map<ConnectionState, Set<ConnectionEventListener>> eventListeners = new HashMap<ConnectionState, Set<ConnectionEventListener>>();
+    private final Map<ConnectionState, Set<ConnectionEventListener>> eventListeners = new ConcurrentHashMap<ConnectionState, Set<ConnectionEventListener>>();
     private final URI webSocketUri;
     private final Proxy proxy;