| 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) {
|
|
|