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

Side by Side Diff: runtime/observatory/lib/src/repositories/event.dart

Issue 2299893003: Converted Observatory logging-page element (Closed)
Patch Set: Updated observatory_sources.gypi Created 4 years, 3 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 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
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
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 }
OLDNEW
« no previous file with comments | « runtime/observatory/lib/src/models/repositories/event.dart ('k') | runtime/observatory/observatory_sources.gypi » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698