|
1 | 1 | package ua.naiksoftware.stomp; |
2 | 2 |
|
3 | | -import android.os.Looper; |
4 | 3 | import android.util.Log; |
5 | 4 |
|
6 | 5 | import org.java_websocket.WebSocket; |
|
27 | 26 | /** |
28 | 27 | * Created by naik on 05.05.16. |
29 | 28 | */ |
30 | | -public class WebSocketsConnectionProvider implements ConnectionProvider { |
| 29 | +/* package */ class WebSocketsConnectionProvider implements ConnectionProvider { |
31 | 30 |
|
32 | 31 | private static final String TAG = WebSocketsConnectionProvider.class.getSimpleName(); |
33 | 32 |
|
34 | 33 | private final String mUri; |
35 | 34 | private final Map<String, String> mConnectHttpHeaders; |
| 35 | + |
| 36 | + private final List<Subscriber<? super LifecycleEvent>> mLifecycleSubscribers; |
| 37 | + private final List<Subscriber<? super String>> mMessagesSubscribers; |
| 38 | + |
36 | 39 | private WebSocketClient mWebSocketClient; |
37 | | - private List<Subscriber<? super LifecycleEvent>> mLifecycleSubscribers; |
38 | | - private List<Subscriber<? super String>> mMessagesSubscribers; |
39 | 40 | private boolean haveConnection; |
40 | 41 | private TreeMap<String, String> mServerHandshakeHeaders; |
41 | 42 |
|
42 | 43 | /** |
43 | 44 | * Support UIR scheme ws://host:port/path |
44 | 45 | * @param connectHttpHeaders may be null |
45 | 46 | */ |
46 | | - public WebSocketsConnectionProvider(String uri, Map<String, String> connectHttpHeaders) { |
| 47 | + /* package */ WebSocketsConnectionProvider(String uri, Map<String, String> connectHttpHeaders) { |
47 | 48 | mUri = uri; |
48 | 49 | mConnectHttpHeaders = connectHttpHeaders != null ? connectHttpHeaders : new HashMap<>(); |
49 | 50 | mLifecycleSubscribers = new ArrayList<>(); |
|
0 commit comments