Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(652)

Side by Side Diff: runtime/observatory/tests/observatory_ui/mocks/repositories/event.dart

Issue 2980733003: Introduced support for external services registration in the ServiceProtocol (Closed)
Patch Set: Address comments Created 3 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 104 matching lines...) Expand 10 before | Expand all | Expand 10 after
115 final _onTimelineEvents = 115 final _onTimelineEvents =
116 new StreamController<M.TimelineEventsEvent>.broadcast(); 116 new StreamController<M.TimelineEventsEvent>.broadcast();
117 get onTimelineEvents => _onTimelineEvents.stream; 117 get onTimelineEvents => _onTimelineEvents.stream;
118 get onTimelineEventsEventHasListener => _onTimelineEvents.hasListener; 118 get onTimelineEventsEventHasListener => _onTimelineEvents.hasListener;
119 119
120 final _onConnectionClosed = 120 final _onConnectionClosed =
121 new StreamController<M.ConnectionClosedEvent>.broadcast(); 121 new StreamController<M.ConnectionClosedEvent>.broadcast();
122 get onConnectionClosed => _onConnectionClosed.stream; 122 get onConnectionClosed => _onConnectionClosed.stream;
123 get onConnectionClosedHasListener => _onConnectionClosed.hasListener; 123 get onConnectionClosedHasListener => _onConnectionClosed.hasListener;
124 124
125 final _onServiceEvent = new StreamController<M.ServiceEvent>.broadcast();
126 get onServiceEvent => _onServiceEvent.stream;
127 get onServiceEventHasListener => _onServiceEvent.hasListener;
128
129 final _onServiceRegistered =
130 new StreamController<M.ServiceRegisteredEvent>.broadcast();
131 get onServiceRegistered => _onServiceRegistered.stream;
132 get onServiceRegisteredHasListener => _onServiceRegistered.hasListener;
133
134 final _onServiceUnregistered =
135 new StreamController<M.ServiceUnregisteredEvent>.broadcast();
136 get onServiceUnregistered => _onServiceUnregistered.stream;
137 get onServiceUnregisteredHasListener => _onServiceUnregistered.hasListener;
138
125 void add(M.Event event) { 139 void add(M.Event event) {
126 _onEvent.add(event); 140 _onEvent.add(event);
127 if (event is M.VMEvent) { 141 if (event is M.VMEvent) {
128 _onVMEvent.add(event); 142 _onVMEvent.add(event);
129 if (event is M.VMUpdateEvent) { 143 if (event is M.VMUpdateEvent) {
130 _onVMUpdate.add(event); 144 _onVMUpdate.add(event);
131 } 145 }
132 } else if (event is M.IsolateEvent) { 146 } else if (event is M.IsolateEvent) {
133 _onIsolateEvent.add(event); 147 _onIsolateEvent.add(event);
134 if (event is M.IsolateStartEvent) { 148 if (event is M.IsolateStartEvent) {
(...skipping 29 matching lines...) Expand all
164 _onBreakpointRemoved.add(event); 178 _onBreakpointRemoved.add(event);
165 } else if (event is M.InspectEvent) { 179 } else if (event is M.InspectEvent) {
166 _onInspect.add(event); 180 _onInspect.add(event);
167 } 181 }
168 } else if (event is M.GCEvent) { 182 } else if (event is M.GCEvent) {
169 _onGCEvent.add(event); 183 _onGCEvent.add(event);
170 } else if (event is M.ExtensionEvent) { 184 } else if (event is M.ExtensionEvent) {
171 _onExtensionEvent.add(event); 185 _onExtensionEvent.add(event);
172 } else if (event is M.TimelineEventsEvent) { 186 } else if (event is M.TimelineEventsEvent) {
173 _onTimelineEvents.add(event); 187 _onTimelineEvents.add(event);
188 } else if (event is M.ServiceEvent) {
189 _onServiceEvent.add(event);
190 if (event is M.ServiceRegisteredEvent) {
191 _onServiceRegistered.add(event);
192 } else if (event is M.ServiceUnregisteredEvent) {
193 _onServiceUnregistered.add(event);
194 }
174 } 195 }
175 } 196 }
176 } 197 }
OLDNEW
« no previous file with comments | « runtime/observatory/observatory_sources.gypi ('k') | runtime/observatory/tests/service/auth_token1_test.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698