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 mocks; | 5 part of mocks; |
6 | 6 |
7 class EventRepositoryMock implements M.EventRepository { | 7 class EventRepositoryMock implements M.EventRepository { |
8 final _onEvent = new StreamController<M.Event>.broadcast(); | 8 final _onEvent = new StreamController<M.Event>.broadcast(); |
9 get onEvent => _onEvent.stream; | 9 get onEvent => _onEvent.stream; |
10 get onEventHasListener => _onEvent.hasListener; | 10 get onEventHasListener => _onEvent.hasListener; |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 get onBreakpointRemovedHasListener => _onBreakpointRemoved.hasListener; | 96 get onBreakpointRemovedHasListener => _onBreakpointRemoved.hasListener; |
97 | 97 |
98 final _onInspect = new StreamController<M.InspectEvent>.broadcast(); | 98 final _onInspect = new StreamController<M.InspectEvent>.broadcast(); |
99 get onInspect => _onInspect.stream; | 99 get onInspect => _onInspect.stream; |
100 get onInspectHasListener => _onInspect.hasListener; | 100 get onInspectHasListener => _onInspect.hasListener; |
101 | 101 |
102 final _onGCEvent = new StreamController<M.GCEvent>.broadcast(); | 102 final _onGCEvent = new StreamController<M.GCEvent>.broadcast(); |
103 get onGCEvent => _onGCEvent.stream; | 103 get onGCEvent => _onGCEvent.stream; |
104 get onGCEventHasListener => _onGCEvent.hasListener; | 104 get onGCEventHasListener => _onGCEvent.hasListener; |
105 | 105 |
| 106 final _onLoggingEvent = new StreamController<M.LoggingEvent>.broadcast(); |
| 107 get onLoggingEvent => _onLoggingEvent.stream; |
| 108 get onLoggingEventHasListener => _onLoggingEvent.hasListener; |
| 109 |
106 final _onExtensionEvent = new StreamController<M.ExtensionEvent>.broadcast(); | 110 final _onExtensionEvent = new StreamController<M.ExtensionEvent>.broadcast(); |
107 get onExtensionEvent => _onExtensionEvent.stream; | 111 get onExtensionEvent => _onExtensionEvent.stream; |
108 get onExtensionEventHasListener => _onExtensionEvent.hasListener; | 112 get onExtensionEventHasListener => _onExtensionEvent.hasListener; |
109 | 113 |
110 final _onTimelineEvents = | 114 final _onTimelineEvents = |
111 new StreamController<M.TimelineEventsEvent>.broadcast(); | 115 new StreamController<M.TimelineEventsEvent>.broadcast(); |
112 get onTimelineEvents => _onTimelineEvents.stream; | 116 get onTimelineEvents => _onTimelineEvents.stream; |
113 get onTimelineEventsEventHasListener => _onTimelineEvents.hasListener; | 117 get onTimelineEventsEventHasListener => _onTimelineEvents.hasListener; |
114 | 118 |
115 final _onConnectionClosed = | 119 final _onConnectionClosed = |
(...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
162 } | 166 } |
163 } else if (event is M.GCEvent) { | 167 } else if (event is M.GCEvent) { |
164 _onGCEvent.add(event); | 168 _onGCEvent.add(event); |
165 } else if (event is M.ExtensionEvent) { | 169 } else if (event is M.ExtensionEvent) { |
166 _onExtensionEvent.add(event); | 170 _onExtensionEvent.add(event); |
167 } else if (event is M.TimelineEventsEvent) { | 171 } else if (event is M.TimelineEventsEvent) { |
168 _onTimelineEvents.add(event); | 172 _onTimelineEvents.add(event); |
169 } | 173 } |
170 } | 174 } |
171 } | 175 } |
OLD | NEW |