| Index: runtime/observatory/lib/src/repositories/event.dart
|
| diff --git a/runtime/observatory/lib/src/repositories/event.dart b/runtime/observatory/lib/src/repositories/event.dart
|
| index 6995f1699957b1ad92d1aa3b5e8acef7614f1de1..4c07f945cb553013f2e6d553874971c36658943f 100644
|
| --- a/runtime/observatory/lib/src/repositories/event.dart
|
| +++ b/runtime/observatory/lib/src/repositories/event.dart
|
| @@ -36,56 +36,64 @@ class EventRepository implements M.EventRepository {
|
|
|
| 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));
|
| + 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));
|
|
|
| - 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)
|
| - : _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),
|
| - onIsolateReload = onIsolateEvent.where((e) => e is M.IsolateReloadEvent),
|
| - onServiceExtensionAdded =
|
| - onIsolateEvent.where((e) => e is M.IsolateReloadEvent),
|
| - onDebugEvent = onDebugEvent,
|
| - onPauseStart = onDebugEvent.where((e) => e is M.PauseStartEvent),
|
| - onPauseExit = onDebugEvent.where((e) => e is M.PauseExitEvent),
|
| - onPauseBreakpoint =
|
| - onDebugEvent.where((e) => e is M.PauseBreakpointEvent),
|
| - onPauseInterrupted =
|
| - onDebugEvent.where((e) => e is M.PauseInterruptedEvent),
|
| - onPauseException = onDebugEvent.where((e) => e is M.PauseExceptionEvent),
|
| - onResume = onDebugEvent.where((e) => e is M.ResumeEvent),
|
| - onBreakpointAdded =
|
| - 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;
|
| + 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)
|
| + : _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),
|
| + onIsolateReload =
|
| + onIsolateEvent.where((e) => e is M.IsolateReloadEvent),
|
| + onServiceExtensionAdded =
|
| + onIsolateEvent.where((e) => e is M.IsolateReloadEvent),
|
| + onDebugEvent = onDebugEvent,
|
| + onPauseStart = onDebugEvent.where((e) => e is M.PauseStartEvent),
|
| + onPauseExit = onDebugEvent.where((e) => e is M.PauseExitEvent),
|
| + onPauseBreakpoint =
|
| + onDebugEvent.where((e) => e is M.PauseBreakpointEvent),
|
| + onPauseInterrupted =
|
| + onDebugEvent.where((e) => e is M.PauseInterruptedEvent),
|
| + onPauseException =
|
| + onDebugEvent.where((e) => e is M.PauseExceptionEvent),
|
| + onResume = onDebugEvent.where((e) => e is M.ResumeEvent),
|
| + onBreakpointAdded =
|
| + 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;
|
|
|
| void add(M.Event e) {
|
| _onEvent.add(e);
|
|
|