@@ -6,7 +6,6 @@ import 'dart:async';
6
6
import 'dart:convert' ;
7
7
import 'dart:html' ;
8
8
9
- import 'package:http/browser_client.dart' ;
10
9
import 'package:logging/logging.dart' ;
11
10
import 'package:stream_channel/stream_channel.dart' ;
12
11
import 'package:uuid/uuid.dart' ;
@@ -20,8 +19,6 @@ class SseClient extends StreamChannelMixin<String> {
20
19
21
20
final _outgoingController = StreamController <String >();
22
21
23
- final _client = BrowserClient ()..withCredentials = true ;
24
-
25
22
final _logger = Logger ('SseClient' );
26
23
27
24
EventSource _eventSource;
@@ -62,7 +59,6 @@ class SseClient extends StreamChannelMixin<String> {
62
59
_eventSource.close ();
63
60
_incomingController.close ();
64
61
_outgoingController.close ();
65
- _client.close ();
66
62
}
67
63
68
64
void _onIncomingControlMessage (Event message) {
@@ -93,7 +89,10 @@ class SseClient extends StreamChannelMixin<String> {
93
89
void _startPostingMessages () async {
94
90
await for (var message in _messages.stream) {
95
91
try {
96
- await _client.post (_serverUrl, body: jsonEncode (message));
92
+ await HttpRequest .request (_serverUrl,
93
+ method: 'POST' ,
94
+ sendData: jsonEncode (message),
95
+ withCredentials: true );
97
96
} on JsonUnsupportedObjectError catch (e) {
98
97
_logger.warning ('Unable to encode outgoing message: $e ' );
99
98
} on ArgumentError catch (e) {
0 commit comments