Add the streamListen and streamCancel rpcs to the vm service.

runtime/observatory/lib/src/elements/debugger.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library debugger_page_element;
 
 import 'dart:async';
 import 'dart:html';
 import 'observatory_element.dart';
-import 'package:observatory/app.dart';
 import 'package:observatory/cli.dart';
 import 'package:observatory/debugger.dart';
 import 'package:observatory/service.dart';
 import 'package:polymer/polymer.dart';
 
 // TODO(turnidge): Move Debugger, DebuggerCommand to debugger library.
 abstract class DebuggerCommand extends Command {
   ObservatoryDebugger debugger;
 
   DebuggerCommand(this.debugger, name, children)
@@ skipping 851 matching lines @@
       _isolate.reload().then((response) {
         // TODO(turnidge): Currently the debugger relies on all libs
         // being loaded.  Fix this.
         var pending = [];
         for (var lib in _isolate.libraries) {
           if (!lib.loaded) {
             pending.add(lib.load());
           }
         }
         Future.wait(pending).then((_) {
-          if (_subscription == null) {
-            _subscription = vm.events.stream.listen(_onEvent);
+          if (_isolateSubscription == null) {
+            _isolateSubscription = vm.isolateEvents.listen(_onEvent);
+          }
+          if (_debugSubscription == null) {
+            _debugSubscription = vm.debugEvents.listen(_onEvent);
           }
           _refreshStack(isolate.pauseEvent).then((_) {
             reportStatus();
           });
         }).catchError((_) {
           // Error loading libraries, try and display stack.
           _refreshStack(isolate.pauseEvent).then((_) {
             reportStatus();
           });
         });
       });
     } else {
       reportStatus();
     }
   }
 
   set isolate(Isolate iso) {
     // Setting the page's isolate will trigger updateIsolate to be called.
     //
     // TODO(turnidge): Rework ownership of the ObservatoryDebugger in another
     // change.
     page.isolate = iso;
   }
   Isolate get isolate => _isolate;
   Isolate _isolate;
-  var _subscription;
+  var _isolateSubscription;
+  var _debugSubscription;
 
   void init() {
     console.newline();
     console.printBold("Type 'h' for help");
     // Wait a bit and if polymer still hasn't set up the isolate,
     // report this to the user.
     new Timer(const Duration(seconds:1), () {
       if (isolate == null) {
         reportStatus();
       }
@@ skipping 246 matching lines @@
     return cmd.historyPrev(command);
   }
 
   String historyNext(String command) {
     return cmd.historyNext(command);
   }
 }
 
 @CustomTag('debugger-page')
 class DebuggerPageElement extends ObservatoryElement {
-  @published ObservatoryApplication app;
   @published Isolate isolate;
 
   isolateChanged(oldValue) {
     if (isolate != null) {
       debugger.updateIsolate(isolate);
     }
   }
   ObservatoryDebugger debugger = new ObservatoryDebugger();
 
   DebuggerPageElement.created() : super.created() {
@@ skipping 480 matching lines @@
           default:
             busy = false;
             break;
         }
       });
   }
 
   DebuggerInputElement.created() : super.created();
 }