Add the streamListen and streamCancel rpcs to the vm service.

runtime/observatory/lib/src/app/application.dart

 // Copyright (c) 2013, 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.
 
 part of app;
 
 class Notification {
   Notification.fromEvent(this.event);
   Notification.fromException(this.exception, this.stacktrace);
 
@@ skipping 35 matching lines @@
       vm.onDisconnect.then((String reason) {
         if (this.vm != vm) {
           // This disconnect event occured *after* a new VM was installed.
           return;
         }
         notifications.add(
             new Notification.fromEvent(
                 new ServiceEvent.connectionClosed(reason)));
       });
 
-      vm.events.stream.listen(_onEvent);
+      vm.isolateEvents.listen(_onEvent);
+      vm.debugEvents.listen(_onEvent);
     }
     _vm = vm;
   }
   final TargetManager targets;
   @reflectable final ObservatoryApplicationElement rootElement;
 
   TraceViewElement _traceView = null;
 
   @reflectable ServiceObject lastErrorOrException;
   @observable ObservableList<Notification> notifications =
@@ skipping 14 matching lines @@
         return (event != null &&
                 event.isolate == isolate &&
                 event.isPauseEvent);
       });
   }
 
   void _onEvent(ServiceEvent event) {
     switch(event.eventType) {
       case ServiceEvent.kIsolateStart:
       case ServiceEvent.kIsolateUpdate:
-      case ServiceEvent.kGraph:
       case ServiceEvent.kBreakpointAdded:
       case ServiceEvent.kBreakpointResolved:
       case ServiceEvent.kBreakpointRemoved:
-      case ServiceEvent.kGC:
         // Ignore for now.
         break;
 
       case ServiceEvent.kIsolateExit:
       case ServiceEvent.kResume:
         removePauseEvents(event.isolate);
         break;
 
       case ServiceEvent.kPauseStart:
       case ServiceEvent.kPauseExit:
       case ServiceEvent.kPauseBreakpoint:
       case ServiceEvent.kPauseInterrupted:
       case ServiceEvent.kPauseException:
         removePauseEvents(event.isolate);
         notifications.add(new Notification.fromEvent(event));
         break;
 
       case ServiceEvent.kInspect:
         notifications.add(new Notification.fromEvent(event));
         break;
 
       default:
         // Ignore unrecognized events.
-        Logger.root.severe('Unrecognized event: $event');
+        Logger.root.severe('Ignoring unexpected event: $event');
         break;
     }
   }
 
   void _registerPages() {
     _pageRegistry.add(new VMPage(this));
     _pageRegistry.add(new FlagsPage(this));
     _pageRegistry.add(new InspectPage(this));
     _pageRegistry.add(new ClassTreePage(this));
     _pageRegistry.add(new DebuggerPage(this));
@@ skipping 86 matching lines @@
     this.vm = new FakeVM(crashDump['result']);
     app.locationManager.go('#/vm');
   }
 
   void handleException(e, st) {
     // TODO(turnidge): Report this failure via analytics.
     Logger.root.warning('Caught exception: ${e}\n${st}');
     notifications.add(new Notification.fromException(e, st));
   }
 }