Introduced support for external services registration in the ServiceProtocol

runtime/observatory/lib/src/repositories/event.dart

 // Copyright (c) 2016, 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 repositories;
 
 class EventRepository implements M.EventRepository {
   final StreamController<M.Event> _onEvent;
   Stream<M.Event> get onEvent => _onEvent.stream;
 
@@ skipping 15 matching lines @@
   final Stream<M.ResumeEvent> onResume;
   final Stream<M.BreakpointAddedEvent> onBreakpointAdded;
   final Stream<M.BreakpointResolvedEvent> onBreakpointResolved;
   final Stream<M.BreakpointRemovedEvent> onBreakpointRemoved;
   final Stream<M.InspectEvent> onInspect;
   final Stream<M.GCEvent> onGCEvent;
   final Stream<M.LoggingEvent> onLoggingEvent;
   final Stream<M.ExtensionEvent> onExtensionEvent;
   final Stream<M.TimelineEventsEvent> onTimelineEvents;
   final Stream<M.ConnectionClosedEvent> onConnectionClosed;
+  final Stream<M.ServiceEvent> onServiceEvent;
+  final Stream<M.ServiceRegisteredEvent> onServiceRegistered;
+  final Stream<M.ServiceUnregisteredEvent> onServiceUnregistered;
 
   EventRepository() : this._(new StreamController.broadcast());
 
   EventRepository._(StreamController controller)
       : this.__(
             controller,
             controller.stream.where((e) => e is M.VMEvent),
             controller.stream.where((e) => e is M.IsolateEvent),
             controller.stream.where((e) => e is M.DebugEvent),
             controller.stream.where((e) => e is M.GCEvent),
             controller.stream.where((e) => e is M.LoggingEvent),
             controller.stream.where((e) => e is M.ExtensionEvent),
             controller.stream.where((e) => e is M.TimelineEventsEvent),
-            controller.stream.where((e) => e is M.ConnectionClosedEvent));
+            controller.stream.where((e) => e is M.ConnectionClosedEvent),
+            controller.stream.where((e) => e is M.ServiceEvent));
 
   EventRepository.__(
       StreamController controller,
       Stream<M.VMEvent> onVMEvent,
       Stream<M.IsolateEvent> onIsolateEvent,
       Stream<M.DebugEvent> onDebugEvent,
       Stream<M.GCEvent> onGCEvent,
       Stream<M.LoggingEvent> onLoggingEvent,
       Stream<M.ExtensionEvent> onExtensionEvent,
       Stream<M.TimelineEventsEvent> onTimelineEvents,
-      Stream<M.ConnectionClosedEvent> onConnectionClosed)
+      Stream<M.ConnectionClosedEvent> onConnectionClosed,
+      Stream<M.ServiceEvent> onServiceEvent)
       : _onEvent = controller,
         onVMEvent = onVMEvent,
         onVMUpdate = onVMEvent.where((e) => e is M.VMUpdateEvent),
         onIsolateEvent = onIsolateEvent,
         onIsolateStart = onIsolateEvent.where((e) => e is M.IsolateStartEvent),
         onIsolateRunnable =
             onIsolateEvent.where((e) => e is M.IsolateRunnableEvent),
         onIsolateExit = onIsolateEvent.where((e) => e is M.IsolateExitEvent),
         onIsolateUpdate =
             onIsolateEvent.where((e) => e is M.IsolateUpdateEvent),
@@ skipping 15 matching lines @@
             onDebugEvent.where((e) => e is M.BreakpointAddedEvent),
         onBreakpointResolved =
             onDebugEvent.where((e) => e is M.BreakpointResolvedEvent),
         onBreakpointRemoved =
             onDebugEvent.where((e) => e is M.BreakpointRemovedEvent),
         onInspect = onDebugEvent.where((e) => e is M.InspectEvent),
         onGCEvent = onGCEvent,
         onLoggingEvent = onLoggingEvent,
         onExtensionEvent = onExtensionEvent,
         onTimelineEvents = onTimelineEvents,
-        onConnectionClosed = onConnectionClosed;
+        onConnectionClosed = onConnectionClosed,
+        onServiceEvent = onServiceEvent,
+        onServiceRegistered =
+            onServiceEvent.where((e) => e is M.ServiceRegisteredEvent),
+        onServiceUnregistered =
+            onServiceEvent.where((e) => e is M.ServiceUnregisteredEvent);
 
   void add(M.Event e) {
     _onEvent.add(e);
   }
 }