File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
src/main/java/io/socket/client Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 9
9
import org .json .JSONObject ;
10
10
11
11
import java .util .*;
12
+ import java .util .concurrent .ConcurrentHashMap ;
12
13
import java .util .concurrent .ConcurrentLinkedQueue ;
13
14
import java .util .logging .Level ;
14
15
import java .util .logging .Logger ;
@@ -59,7 +60,7 @@ public class Socket extends Emitter {
59
60
private String nsp ;
60
61
private Manager io ;
61
62
private Map <String , String > auth ;
62
- private Map <Integer , Ack > acks = new HashMap <>();
63
+ private Map <Integer , Ack > acks = new ConcurrentHashMap <>();
63
64
private Queue <On .Handle > subs ;
64
65
private final Queue <List <Object >> receiveBuffer = new ConcurrentLinkedQueue <>();
65
66
private final Queue <Packet <JSONArray >> sendBuffer = new ConcurrentLinkedQueue <>();
You can’t perform that action at this time.
0 commit comments