| OLD | NEW |
| 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 part of repositories; | 5 part of repositories; |
| 6 | 6 |
| 7 class EventRepository implements M.EventRepository { | 7 class EventRepository implements M.EventRepository { |
| 8 final StreamController<M.Event> _onEvent; | 8 final StreamController<M.Event> _onEvent; |
| 9 Stream<M.Event> get onEvent => _onEvent.stream; | 9 Stream<M.Event> get onEvent => _onEvent.stream; |
| 10 | 10 |
| (...skipping 11 matching lines...) Expand all Loading... |
| 22 final Stream<M.PauseExitEvent> onPauseExit; | 22 final Stream<M.PauseExitEvent> onPauseExit; |
| 23 final Stream<M.PauseBreakpointEvent> onPauseBreakpoint; | 23 final Stream<M.PauseBreakpointEvent> onPauseBreakpoint; |
| 24 final Stream<M.PauseInterruptedEvent> onPauseInterrupted; | 24 final Stream<M.PauseInterruptedEvent> onPauseInterrupted; |
| 25 final Stream<M.PauseExceptionEvent> onPauseException; | 25 final Stream<M.PauseExceptionEvent> onPauseException; |
| 26 final Stream<M.ResumeEvent> onResume; | 26 final Stream<M.ResumeEvent> onResume; |
| 27 final Stream<M.BreakpointAddedEvent> onBreakpointAdded; | 27 final Stream<M.BreakpointAddedEvent> onBreakpointAdded; |
| 28 final Stream<M.BreakpointResolvedEvent> onBreakpointResolved; | 28 final Stream<M.BreakpointResolvedEvent> onBreakpointResolved; |
| 29 final Stream<M.BreakpointRemovedEvent> onBreakpointRemoved; | 29 final Stream<M.BreakpointRemovedEvent> onBreakpointRemoved; |
| 30 final Stream<M.InspectEvent> onInspect; | 30 final Stream<M.InspectEvent> onInspect; |
| 31 final Stream<M.GCEvent> onGCEvent; | 31 final Stream<M.GCEvent> onGCEvent; |
| 32 final Stream<M.LoggingEvent> onLoggingEvent; |
| 32 final Stream<M.ExtensionEvent> onExtensionEvent; | 33 final Stream<M.ExtensionEvent> onExtensionEvent; |
| 33 final Stream<M.TimelineEventsEvent> onTimelineEvents; | 34 final Stream<M.TimelineEventsEvent> onTimelineEvents; |
| 34 final Stream<M.ConnectionClosedEvent> onConnectionClosed; | 35 final Stream<M.ConnectionClosedEvent> onConnectionClosed; |
| 35 | 36 |
| 36 EventRepository() : this._(new StreamController.broadcast()); | 37 EventRepository() : this._(new StreamController.broadcast()); |
| 37 | 38 |
| 38 EventRepository._(StreamController controller) : this.__(controller, | 39 EventRepository._(StreamController controller) : this.__(controller, |
| 39 controller.stream.where((e) => e is M.VMEvent), | 40 controller.stream.where((e) => e is M.VMEvent), |
| 40 controller.stream.where((e) => e is M.IsolateEvent), | 41 controller.stream.where((e) => e is M.IsolateEvent), |
| 41 controller.stream.where((e) => e is M.DebugEvent), | 42 controller.stream.where((e) => e is M.DebugEvent), |
| 42 controller.stream.where((e) => e is M.GCEvent), | 43 controller.stream.where((e) => e is M.GCEvent), |
| 44 controller.stream.where((e) => e is M.LoggingEvent), |
| 43 controller.stream.where((e) => e is M.ExtensionEvent), | 45 controller.stream.where((e) => e is M.ExtensionEvent), |
| 44 controller.stream.where((e) => e is M.TimelineEventsEvent), | 46 controller.stream.where((e) => e is M.TimelineEventsEvent), |
| 45 controller.stream.where((e) => e is M.ConnectionClosedEvent)); | 47 controller.stream.where((e) => e is M.ConnectionClosedEvent)); |
| 46 | 48 |
| 47 EventRepository.__(StreamController controller, | 49 EventRepository.__(StreamController controller, |
| 48 Stream<M.VMEvent> onVMEvent, Stream<M.IsolateEvent> onIsolateEvent, | 50 Stream<M.VMEvent> onVMEvent, Stream<M.IsolateEvent> onIsolateEvent, |
| 49 Stream<M.DebugEvent> onDebugEvent, Stream<M.GCEvent> onGCEvent, | 51 Stream<M.DebugEvent> onDebugEvent, Stream<M.GCEvent> onGCEvent, |
| 52 Stream<M.LoggingEvent> onLoggingEvent, |
| 50 Stream<M.ExtensionEvent> onExtensionEvent, | 53 Stream<M.ExtensionEvent> onExtensionEvent, |
| 51 Stream<M.TimelineEventsEvent> onTimelineEvents, | 54 Stream<M.TimelineEventsEvent> onTimelineEvents, |
| 52 Stream<M.ConnectionClosedEvent> onConnectionClosed) | 55 Stream<M.ConnectionClosedEvent> onConnectionClosed) |
| 53 : _onEvent = controller, | 56 : _onEvent = controller, |
| 54 onVMEvent = onVMEvent, | 57 onVMEvent = onVMEvent, |
| 55 onVMUpdate = onVMEvent.where((e) => e is M.VMUpdateEvent), | 58 onVMUpdate = onVMEvent.where((e) => e is M.VMUpdateEvent), |
| 56 onIsolateEvent = onIsolateEvent, | 59 onIsolateEvent = onIsolateEvent, |
| 57 onIsolateStart = onIsolateEvent.where((e) => e is M.IsolateStartEvent), | 60 onIsolateStart = onIsolateEvent.where((e) => e is M.IsolateStartEvent), |
| 58 onIsolateRunnable = | 61 onIsolateRunnable = |
| 59 onIsolateEvent.where((e) => e is M.IsolateRunnableEvent), | 62 onIsolateEvent.where((e) => e is M.IsolateRunnableEvent), |
| (...skipping 12 matching lines...) Expand all Loading... |
| 72 onPauseException = onDebugEvent.where((e) => e is M.PauseExceptionEvent), | 75 onPauseException = onDebugEvent.where((e) => e is M.PauseExceptionEvent), |
| 73 onResume = onDebugEvent.where((e) => e is M.ResumeEvent), | 76 onResume = onDebugEvent.where((e) => e is M.ResumeEvent), |
| 74 onBreakpointAdded = | 77 onBreakpointAdded = |
| 75 onDebugEvent.where((e) => e is M.BreakpointAddedEvent), | 78 onDebugEvent.where((e) => e is M.BreakpointAddedEvent), |
| 76 onBreakpointResolved = | 79 onBreakpointResolved = |
| 77 onDebugEvent.where((e) => e is M.BreakpointResolvedEvent), | 80 onDebugEvent.where((e) => e is M.BreakpointResolvedEvent), |
| 78 onBreakpointRemoved = | 81 onBreakpointRemoved = |
| 79 onDebugEvent.where((e) => e is M.BreakpointRemovedEvent), | 82 onDebugEvent.where((e) => e is M.BreakpointRemovedEvent), |
| 80 onInspect = onDebugEvent.where((e) => e is M.InspectEvent), | 83 onInspect = onDebugEvent.where((e) => e is M.InspectEvent), |
| 81 onGCEvent = onGCEvent, | 84 onGCEvent = onGCEvent, |
| 85 onLoggingEvent = onLoggingEvent, |
| 82 onExtensionEvent = onExtensionEvent, | 86 onExtensionEvent = onExtensionEvent, |
| 83 onTimelineEvents = onTimelineEvents, | 87 onTimelineEvents = onTimelineEvents, |
| 84 onConnectionClosed = onConnectionClosed; | 88 onConnectionClosed = onConnectionClosed; |
| 85 | 89 |
| 86 void add(M.Event e) { | 90 void add(M.Event e) { |
| 87 _onEvent.add(e); | 91 _onEvent.add(e); |
| 88 } | 92 } |
| 89 } | 93 } |
| OLD | NEW |