| Index: runtime/observatory/lib/src/elements/isolate_ref.dart
|
| diff --git a/runtime/observatory/lib/src/elements/isolate_ref.dart b/runtime/observatory/lib/src/elements/isolate_ref.dart
|
| index 730a4383800b11a6be12506e3f2a086943cafa42..05c137d572186c4105618d85daae55e8ffa1cd99 100644
|
| --- a/runtime/observatory/lib/src/elements/isolate_ref.dart
|
| +++ b/runtime/observatory/lib/src/elements/isolate_ref.dart
|
| @@ -4,10 +4,65 @@
|
|
|
| library isolate_ref_element;
|
|
|
| -import 'package:polymer/polymer.dart';
|
| -import 'service_ref.dart';
|
| +import 'dart:html';
|
| +import 'dart:async';
|
| +import 'package:observatory/models.dart' as M
|
| + show IsolateRef, IsolateUpdateEvent;
|
| +import 'package:observatory/src/elements/helpers/tag.dart';
|
| +import 'package:observatory/src/elements/helpers/rendering_scheduler.dart';
|
| +
|
| +class IsolateRefElement extends HtmlElement implements Renderable {
|
| + static const tag = const Tag<IsolateRefElement>('isolate-ref-wrapped');
|
| +
|
| + RenderingScheduler<IsolateRefElement> _r;
|
| +
|
| + Stream<RenderedEvent<IsolateRefElement>> get onRendered => _r.onRendered;
|
| +
|
| + Stream<M.IsolateUpdateEvent> _updates;
|
| + StreamSubscription _updatesSubscription;
|
| + M.IsolateRef _isolate;
|
| +
|
| + M.IsolateRef get isolate => _isolate;
|
| +
|
| + factory IsolateRefElement(M.IsolateRef isolate,
|
| + Stream<M.IsolateUpdateEvent> updates, {RenderingQueue queue}) {
|
| + assert(isolate != null);
|
| + assert(updates != null);
|
| + IsolateRefElement e = document.createElement(tag.name);
|
| + e._r = new RenderingScheduler(e, queue: queue);
|
| + e._isolate = isolate;
|
| + e._updates = updates;
|
| + return e;
|
| + }
|
|
|
| -@CustomTag('isolate-ref')
|
| -class IsolateRefElement extends ServiceRefElement {
|
| IsolateRefElement.created() : super.created();
|
| +
|
| + @override
|
| + void attached() {
|
| + super.attached();
|
| + assert(_isolate != null);
|
| + assert(_updates != null);
|
| + _r.enable();
|
| + _updatesSubscription = _updates
|
| + .where((M.IsolateUpdateEvent e) => e.isolate.id == isolate.id)
|
| + .listen((M.IsolateUpdateEvent e) { _isolate = e.isolate; _r.dirty(); });
|
| + }
|
| +
|
| + @override
|
| + void detached() {
|
| + super.detached(); _r.disable(notify: true);
|
| + children = [];
|
| + assert(_updatesSubscription != null);
|
| + _updatesSubscription.cancel();
|
| + _updatesSubscription = null;
|
| + }
|
| +
|
| + void render() {
|
| + children = [
|
| + new AnchorElement(href:
|
| + '#/inspect?isolateId=${Uri.encodeComponent(isolate.id)}')
|
| + ..text = 'Isolate ${isolate.number} (${isolate.name})'
|
| + ..classes = ['isolate-ref']
|
| + ];
|
| + }
|
| }
|
|
|