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

Unified Diff: pkg/observe/lib/src/list_path_observer.dart

Issue 817483003: delete observe from the repo (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « pkg/observe/lib/src/list_diff.dart ('k') | pkg/observe/lib/src/messages.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: pkg/observe/lib/src/list_path_observer.dart
diff --git a/pkg/observe/lib/src/list_path_observer.dart b/pkg/observe/lib/src/list_path_observer.dart
deleted file mode 100644
index 22a81995989483ad5876c4e2328c05a4f44e3584..0000000000000000000000000000000000000000
--- a/pkg/observe/lib/src/list_path_observer.dart
+++ /dev/null
@@ -1,73 +0,0 @@
-// 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.
-
-library observe.src.list_path_observer;
-
-import 'dart:async';
-import 'package:observe/observe.dart';
-
-// Inspired by ArrayReduction at:
-// https://raw.github.com/rafaelw/ChangeSummary/master/util/array_reduction.js
-// The main difference is we support anything on the rich Dart Iterable API.
-
-/// Observes a path starting from each item in the list.
-@deprecated
-class ListPathObserver<E, P> extends ChangeNotifier {
- final ObservableList<E> list;
- final String _itemPath;
- final List<PathObserver> _observers = <PathObserver>[];
- StreamSubscription _sub;
- bool _scheduled = false;
- Iterable<P> _value;
-
- ListPathObserver(this.list, String path)
- : _itemPath = path {
-
- // TODO(jmesserly): delay observation until we are observed.
- _sub = list.listChanges.listen((records) {
- for (var record in records) {
- _observeItems(record.addedCount - record.removed.length);
- }
- _scheduleReduce(null);
- });
-
- _observeItems(list.length);
- _reduce();
- }
-
- @reflectable Iterable<P> get value => _value;
-
- void dispose() {
- if (_sub != null) _sub.cancel();
- _observers.forEach((o) => o.close());
- _observers.clear();
- }
-
- void _reduce() {
- _scheduled = false;
- var newValue = _observers.map((o) => o.value);
- _value = notifyPropertyChange(#value, _value, newValue);
- }
-
- void _scheduleReduce(_) {
- if (_scheduled) return;
- _scheduled = true;
- scheduleMicrotask(_reduce);
- }
-
- void _observeItems(int lengthAdjust) {
- if (lengthAdjust > 0) {
- for (int i = 0; i < lengthAdjust; i++) {
- int len = _observers.length;
- var pathObs = new PathObserver(list, '[$len].$_itemPath');
- pathObs.open(_scheduleReduce);
- _observers.add(pathObs);
- }
- } else if (lengthAdjust < 0) {
- for (int i = 0; i < -lengthAdjust; i++) {
- _observers.removeLast().close();
- }
- }
- }
-}
« no previous file with comments | « pkg/observe/lib/src/list_diff.dart ('k') | pkg/observe/lib/src/messages.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698