Skip to content

Commit f33bc9a

Browse files
authored
Merge pull request #116 from realtybaron/fix_115
Fix 115
2 parents cc52594 + 894b180 commit f33bc9a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/pusher/client/connection/websocket/WebSocketConnection.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import java.net.Proxy;
44
import java.net.URI;
55
import java.net.URISyntaxException;
6-
import java.util.HashMap;
6+
import java.util.Collections;
77
import java.util.HashSet;
88
import java.util.Map;
99
import java.util.Set;
@@ -55,7 +55,7 @@ public WebSocketConnection(
5555
this.factory = factory;
5656

5757
for (final ConnectionState state : ConnectionState.values()) {
58-
eventListeners.put(state, new HashSet<ConnectionEventListener>());
58+
eventListeners.put(state, Collections.newSetFromMap(new ConcurrentHashMap<ConnectionEventListener, Boolean>()));
5959
}
6060
}
6161

0 commit comments

Comments
 (0)