Add the streamListen and streamCancel rpcs to the vm service.

runtime/observatory/tests/service/isolate_lifecycle_test.dart

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