We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cbe0cfa commit d2cac6dCopy full SHA for d2cac6d
lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java
@@ -11,6 +11,7 @@
11
import java.util.Map;
12
import java.util.Set;
13
import java.util.UUID;
14
+import java.util.concurrent.CopyOnWriteArrayList;
15
16
import rx.Observable;
17
import rx.Subscriber;
@@ -40,7 +41,7 @@ public class StompClient {
40
41
42
public StompClient(ConnectionProvider connectionProvider) {
43
mConnectionProvider = connectionProvider;
- mWaitConnectionObservables = new ArrayList<>();
44
+ mWaitConnectionObservables = new CopyOnWriteArrayList<>();
45
}
46
47
/**
0 commit comments