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 |