File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change 1
1
import 'dart:async' ;
2
2
import 'dart:convert' as convert;
3
3
4
- import 'package:async/async.dart' ;
5
4
import 'package:http/http.dart' as http;
6
5
import 'package:powersync/src/abort_controller.dart' ;
7
6
import 'package:powersync/src/exceptions.dart' ;
@@ -171,7 +170,7 @@ class StreamingSyncImplementation {
171
170
// This has the potential (in rare cases) to affect the crudThrottleTime,
172
171
// but it should not result in excessive uploads since the
173
172
// sync reconnects are also throttled.
174
- await for (var _ in StreamGroup . merge (
173
+ await for (var _ in mergeStreams (
175
174
[crudUpdateTriggerStream, _internalCrudTriggerController.stream])) {
176
175
if (_abort? .aborted == true ) {
177
176
break ;
Original file line number Diff line number Diff line change @@ -31,7 +31,7 @@ class TestHttpServerHelper {
31
31
});
32
32
});
33
33
34
- _server = await io.serve (router, 'localhost' , 0 );
34
+ _server = await io.serve (router.call , 'localhost' , 0 );
35
35
print ('Test server running at ${_server .address }:${_server .port }' );
36
36
}
37
37
You can’t perform that action at this time.
0 commit comments