Index: runtime/observatory/lib/src/elements/isolate_ref_wrapper.dart |
diff --git a/runtime/observatory/lib/src/elements/isolate_ref_wrapper.dart b/runtime/observatory/lib/src/elements/isolate_ref_wrapper.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..dc78739cbae4321afcef45ecfa59076d2e1566e5 |
--- /dev/null |
+++ b/runtime/observatory/lib/src/elements/isolate_ref_wrapper.dart |
@@ -0,0 +1,78 @@ |
+// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
+// for details. All rights reserved. Use of this source code is governed by a |
+// BSD-style license that can be found in the LICENSE file. |
+ |
+import 'dart:html'; |
+import 'dart:async'; |
+ |
+import 'package:observatory/app.dart'; |
+import 'package:observatory/models.dart' show IsolateUpdateEvent; |
+import 'package:observatory/mocks.dart' show IsolateUpdateEventMock; |
+import 'package:observatory/service_html.dart' show Isolate; |
+import 'package:observatory/src/elements/isolate_ref.dart'; |
+import 'package:observatory/src/elements/helpers/tag.dart'; |
+import 'package:observatory/src/elements/shims/binding.dart'; |
+ |
+class IsolateRefElementWrapper extends HtmlElement { |
+ |
+ static final binder = new Binder<IsolateRefElementWrapper>( |
+ const [const Binding('ref')]); |
+ |
+ static const tag = const Tag<IsolateRefElementWrapper>('isolate-ref'); |
+ |
+ final StreamController<IsolateUpdateEvent> _updatesController = |
+ new StreamController<IsolateUpdateEvent>(); |
+ Stream<IsolateUpdateEvent> _updates; |
+ StreamSubscription _subscription; |
+ |
+ Isolate _isolate; |
+ Isolate get ref => _isolate; |
+ void set ref(Isolate ref) { _isolate = ref; _detached(); _attached(); } |
+ |
+ IsolateRefElementWrapper.created() : super.created() { |
+ _updates = _updatesController.stream.asBroadcastStream(); |
+ binder.registerCallback(this); |
+ createShadowRoot(); |
+ render(); |
+ } |
+ |
+ @override |
+ void attached() { |
+ super.attached(); |
+ _attached(); |
+ } |
+ |
+ void _attached() { |
+ if (ref != null) { |
+ _subscription = ref.changes.listen((_) { |
+ _updatesController.add(new IsolateUpdateEventMock(isolate: ref)); |
+ }); |
+ } |
+ render(); |
+ } |
+ |
+ @override |
+ void detached() { |
+ super.detached(); |
+ _detached(); |
+ } |
+ |
+ void _detached() { |
+ if (_subscription != null) { |
+ _subscription.cancel(); |
+ _subscription = null; |
+ } |
+ } |
+ |
+ void render() { |
+ shadowRoot.children = []; |
+ if (ref == null) return; |
+ |
+ shadowRoot.children = [ |
+ new StyleElement() |
+ ..text = '@import "packages/observatory/src/elements/css/shared.css";', |
+ new IsolateRefElement(_isolate, _updates, |
+ queue: ObservatoryApplication.app.queue) |
+ ]; |
+ } |
+} |