Skip to content

Commit cf5e4b5

Browse files
author
Jonah Williams
authored
[flutter_tools] fix routing test (flutter#54313)
1 parent 412e4dd commit cf5e4b5

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

packages/flutter_tools/lib/src/vmservice.dart

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -350,22 +350,24 @@ class VMService implements vm_service.VmService {
350350
final io.WebSocket channel = await _openChannel(wsUri.toString(), compression: compression);
351351
final StreamController<dynamic> primary = StreamController<dynamic>();
352352
final StreamController<dynamic> secondary = StreamController<dynamic>();
353+
// Create an instance of the package:vm_service API in addition to the flutter
354+
// tool's to allow gradual migration.
355+
final Completer<void> streamClosedCompleter = Completer<void>();
353356

354357
channel.listen((dynamic data) {
355358
primary.add(data);
356359
secondary.add(data);
357360
}, onDone: () {
358361
primary.close();
359362
secondary.close();
363+
if (!streamClosedCompleter.isCompleted) {
364+
streamClosedCompleter.complete();
365+
}
360366
}, onError: (dynamic error, StackTrace stackTrace) {
361367
primary.addError(error, stackTrace);
362368
secondary.addError(error, stackTrace);
363369
});
364370

365-
// Create an instance of the package:vm_service API in addition to the flutter
366-
// tool's to allow gradual migration.
367-
final Completer<void> streamClosedCompleter = Completer<void>();
368-
369371
final vm_service.VmService delegateService = vm_service.VmService(
370372
primary.stream,
371373
channel.add,

0 commit comments

Comments
 (0)