Index: runtime/observatory/tests/service/isolate_lifecycle_test.dart |
diff --git a/runtime/observatory/tests/service/isolate_lifecycle_test.dart b/runtime/observatory/tests/service/isolate_lifecycle_test.dart |
index f8b2f97641c5ecd0712a0e6180e1dd175981ef06..be878a222ca6b9aa714ae88f93bdca806ef724e1 100644 |
--- a/runtime/observatory/tests/service/isolate_lifecycle_test.dart |
+++ b/runtime/observatory/tests/service/isolate_lifecycle_test.dart |
@@ -54,8 +54,7 @@ var tests = [ |
(VM vm) async { |
// Wait for the testee to start all of the isolates. |
if (vm.isolates.length != spawnCount + 1) { |
- await processServiceEvents(vm, VM.kIsolateEventStreamId, |
- (event, sub, completer) { |
+ await processServiceEvents(vm, (event, sub, completer) { |
if (event.eventType == ServiceEvent.kIsolateStart) { |
if (vm.isolates.length == spawnCount + 1) { |
sub.cancel(); |
@@ -77,8 +76,7 @@ var tests = [ |
(VM vm) async { |
// Wait for all spawned isolates to hit pause-at-exit. |
if (numPaused(vm) != spawnCount) { |
- await processServiceEvents(vm, VM.kDebugEventStreamId, |
- (event, sub, completer) { |
+ await processServiceEvents(vm, (event, sub, completer) { |
if (event.eventType == ServiceEvent.kPauseExit) { |
if (numPaused(vm) == spawnCount) { |
sub.cancel(); |
@@ -94,8 +92,7 @@ var tests = [ |
(VM vm) async { |
var resumedReceived = 0; |
- var eventsDone = processServiceEvents(vm, VM.kIsolateEventStreamId, |
- (event, sub, completer) { |
+ var eventsDone = processServiceEvents(vm, (event, sub, completer) { |
if (event.eventType == ServiceEvent.kIsolateExit) { |
resumedReceived++; |
if (resumedReceived == resumeCount) { |