Add the streamListen and streamCancel rpcs to the vm service.

runtime/observatory/tests/service/debugging_test.dart

Index: runtime/observatory/tests/service/debugging_test.dart
diff --git a/runtime/observatory/tests/service/debugging_test.dart b/runtime/observatory/tests/service/debugging_test.dart
index a4ce042f4bef98a74a08a4ed10fe945bcb87b8a2..d69e2e83d5d28d3bae3a6e7813187cf6b5f7a2b8 100644
--- a/runtime/observatory/tests/service/debugging_test.dart
+++ b/runtime/observatory/tests/service/debugging_test.dart
@@ -29,7 +29,7 @@ var tests = [
 (Isolate isolate) async {
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kPauseInterrupted) {
       subscription.cancel();
       completer.complete();
@@ -43,7 +43,7 @@ var tests = [
 (Isolate isolate) async {
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kResume) {
       subscription.cancel();
       completer.complete();
@@ -60,7 +60,7 @@ var tests = [
   // Set up a listener to wait for breakpoint events.
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kPauseBreakpoint) {
       print('Breakpoint reached');
       subscription.cancel();
@@ -99,7 +99,7 @@ var tests = [
   // Set up a listener to wait for breakpoint events.
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kPauseBreakpoint) {
       print('Breakpoint reached');
       subscription.cancel();
@@ -127,7 +127,7 @@ var tests = [
   // Set up a listener to wait for breakpoint events.
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kBreakpointRemoved) {
       print('Breakpoint removed');
       expect(isolate.breakpoints.length, equals(0));
@@ -146,7 +146,7 @@ var tests = [
 (Isolate isolate) async {
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kResume) {
       subscription.cancel();
       completer.complete();
@@ -161,7 +161,7 @@ var tests = [
   // Set up a listener to wait for breakpoint events.
   Completer completer = new Completer();
   var subscription;
-  subscription = isolate.vm.events.stream.listen((ServiceEvent event) {
+  subscription = isolate.vm.debugEvents.listen((ServiceEvent event) {
     if (event.eventType == ServiceEvent.kPauseBreakpoint) {
       print('Breakpoint reached');
       subscription.cancel();