1
1
import 'dart:convert' ;
2
- import 'dart:html' ;
2
+ // ignore: uri_does_not_exist
3
+ import 'dart:html' as HTML;
3
4
4
5
import '../../parse_server_sdk.dart' ;
5
6
@@ -18,7 +19,7 @@ class LiveQuery {
18
19
autoSendSessionId ?? ParseCoreData ().autoSendSessionId ?? true ;
19
20
}
20
21
21
- WebSocket _webSocket;
22
+ HTML . WebSocket _webSocket;
22
23
ParseHTTPClient _client;
23
24
bool _debug;
24
25
bool _sendSessionId;
@@ -64,10 +65,10 @@ class LiveQuery {
64
65
final int requestId = _requestIdGenerator ();
65
66
66
67
try {
67
- _webSocket = WebSocket (_liveQueryURL);
68
+ _webSocket = HTML . WebSocket (_liveQueryURL);
68
69
await _webSocket.onOpen.first;
69
70
70
- if (_webSocket != null && _webSocket.readyState == WebSocket .OPEN ) {
71
+ if (_webSocket != null && _webSocket.readyState == HTML . WebSocket .OPEN ) {
71
72
if (_debug) {
72
73
print ('$_printConstLiveQuery : Socket opened' );
73
74
}
@@ -78,7 +79,7 @@ class LiveQuery {
78
79
}
79
80
}
80
81
81
- _webSocket.onMessage.listen ((MessageEvent e) {
82
+ _webSocket.onMessage.listen ((HTML . MessageEvent e) {
82
83
final dynamic message = e.data;
83
84
if (_debug) {
84
85
print ('$_printConstLiveQuery : Listen: $message ' );
@@ -169,7 +170,7 @@ class LiveQuery {
169
170
}
170
171
171
172
Future <void > unSubscribe () async {
172
- if (_webSocket != null && _webSocket.readyState == WebSocket .OPEN ) {
173
+ if (_webSocket != null && _webSocket.readyState == HTML . WebSocket .OPEN ) {
173
174
_webSocket.sendString (jsonEncode (_unsubscribeMessage));
174
175
if (_debug) {
175
176
print ('$_printConstLiveQuery : Socket closed' );
0 commit comments