Converted Observatory logging-page element

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;
 
 /// The observatory application. Instances of this are created and owned
 /// by the observatory_application custom element.
 class ObservatoryApplication extends Observable {
   static ObservatoryApplication app;
@@ skipping 36 matching lines @@
 
       // TODO(cbernaschina) smart connection of streams in the events object.
       vm.listenEventStream(VM.kVMStream, _onEvent);
       vm.listenEventStream(VM.kIsolateStream, _onEvent);
       vm.listenEventStream(VM.kDebugStream, _onEvent);
     }
     _vm = vm;
   }
 
   StreamSubscription _gcSubscription;
+  StreamSubscription _loggingSubscription;
 
   Future startGCEventListener() async {
     if (_gcSubscription != null || _vm == null) {
       return;
     }
     _gcSubscription = await _vm.listenEventStream(VM.kGCStream, _onEvent);
   }
 
+  Future startLoggingEventListener() async {
+    if (_loggingSubscription != null || _vm == null) {
+      return;
+    }
+    _loggingSubscription =
+        await _vm.listenEventStream(Isolate.kLoggingStream, _onEvent);
+  }
+
   Future stopGCEventListener() async {
     if (_gcSubscription == null) {
       return;
     }
     _gcSubscription.cancel();
     _gcSubscription = null;
   }
 
+  Future stopLoggingEventListener() async {
+    if (_loggingSubscription == null) {
+      return;
+    }
+    _loggingSubscription.cancel();
+    _loggingSubscription = null;
+  }
+
 
   @reflectable final ObservatoryApplicationElement rootElement;
 
   @reflectable ServiceObject lastErrorOrException;
 
   void _initOnce() {
     assert(app == null);
     app = this;
     _registerPages();
     Analytics.initialize();
     // Visit the current page.
     locationManager._visit();
   }
 
   void _deletePauseEvents(e) {
     notifications.deletePauseEvents(isolate: e.isolate);
   }
   void _addNotification(M.Event e) {
     notifications.add(new EventNotification(e));
   }
 
   void _onEvent(ServiceEvent event) {
     assert(event.kind != ServiceEvent.kNone);
-
     M.Event e = createEventFromServiceEvent(event);
     if (e != null) {
       events.add(e);
     }
   }
 
   void _registerPages() {
     _pageRegistry.add(new VMPage(this));
     _pageRegistry.add(new FlagsPage(this));
     _pageRegistry.add(new InspectPage(this));
@@ skipping 110 matching lines @@
     }
 
     // TODO(turnidge): Report this failure via analytics.
     Logger.root.warning('Caught exception: ${e}\n${st}');
     notifications.add(new ExceptionNotification(e, stacktrace: st));
   }
 
   // This map keeps track of which curly-blocks have been expanded by the user.
   Map<String,bool> expansions = {};
 }