Index: packages/observable/lib/src/list_diff.dart |
diff --git a/packages/observe/lib/src/list_diff.dart b/packages/observable/lib/src/list_diff.dart |
similarity index 70% |
rename from packages/observe/lib/src/list_diff.dart |
rename to packages/observable/lib/src/list_diff.dart |
index cbc3f2f8ed413f4a25b4dc8ab698b739ffdc6be3..c16a613c8a061209f7b137cf7f45b1d64b2ea701 100644 |
--- a/packages/observe/lib/src/list_diff.dart |
+++ b/packages/observable/lib/src/list_diff.dart |
@@ -1,18 +1,19 @@ |
-// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
+// Copyright (c) 2016, 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_diff; |
+library observable.src.list_diff; |
-import 'dart:math' as math; |
import 'dart:collection' show UnmodifiableListView; |
+import 'dart:math' as math; |
+ |
import 'change_record.dart' show ChangeRecord; |
/// A summary of an individual change to a [List]. |
/// |
/// Each delta represents that at the [index], [removed] sequence of items were |
/// removed, and counting forward from [index], [addedCount] items were added. |
-class ListChangeRecord extends ChangeRecord { |
+class ListChangeRecord /* TODO(tvolkert): remove */ extends ChangeRecord { |
/// The list that changed. |
final List object; |
@@ -35,28 +36,27 @@ class ListChangeRecord extends ChangeRecord { |
// user. |
int _index, _addedCount; |
- ListChangeRecord._(this.object, this._index, removed, this._addedCount) |
+ ListChangeRecord._(this.object, this._index, List removed, this._addedCount) |
: _removed = removed, |
_unmodifiableRemoved = new UnmodifiableListView(removed); |
factory ListChangeRecord(List object, int index, |
{List removed, int addedCount}) { |
- |
if (removed == null) removed = []; |
if (addedCount == null) addedCount = 0; |
return new ListChangeRecord._(object, index, removed, addedCount); |
} |
- /// Returns true if the provided index was changed by this operation. |
- bool indexChanged(key) { |
- // If key isn't an int, or before the index, then it wasn't changed. |
- if (key is! int || key < index) return false; |
+ /// Returns true if the provided [ref] index was changed by this operation. |
+ bool indexChanged(int ref) { |
+ // If ref is before the index, then it wasn't changed. |
+ if (ref < index) return false; |
// If this was a shift operation, anything after index is changed. |
if (addedCount != removed.length) return true; |
// Otherwise, anything in the update range was changed. |
- return key < index + addedCount; |
+ return ref < index + addedCount; |
} |
String toString() => '#<ListChangeRecord index: $index, ' |
@@ -77,28 +77,28 @@ class ListChangeRecord extends ChangeRecord { |
List<List<int>> _calcEditDistances(List current, int currentStart, |
int currentEnd, List old, int oldStart, int oldEnd) { |
// "Deletion" columns |
- var rowCount = oldEnd - oldStart + 1; |
- var columnCount = currentEnd - currentStart + 1; |
- var distances = new List(rowCount); |
+ int rowCount = oldEnd - oldStart + 1; |
+ int columnCount = currentEnd - currentStart + 1; |
+ List<List<int>> distances = new List<List<int>>(rowCount); |
// "Addition" rows. Initialize null column. |
- for (var i = 0; i < rowCount; i++) { |
+ for (int i = 0; i < rowCount; i++) { |
distances[i] = new List(columnCount); |
distances[i][0] = i; |
} |
// Initialize null row |
- for (var j = 0; j < columnCount; j++) { |
+ for (int j = 0; j < columnCount; j++) { |
distances[0][j] = j; |
} |
- for (var i = 1; i < rowCount; i++) { |
- for (var j = 1; j < columnCount; j++) { |
+ for (int i = 1; i < rowCount; i++) { |
+ for (int j = 1; j < columnCount; j++) { |
if (old[oldStart + i - 1] == current[currentStart + j - 1]) { |
distances[i][j] = distances[i - 1][j - 1]; |
} else { |
- var north = distances[i - 1][j] + 1; |
- var west = distances[i][j - 1] + 1; |
+ int north = distances[i - 1][j] + 1; |
+ int west = distances[i][j - 1] + 1; |
distances[i][j] = math.min(north, west); |
} |
} |
@@ -107,51 +107,51 @@ List<List<int>> _calcEditDistances(List current, int currentStart, |
return distances; |
} |
-const _EDIT_LEAVE = 0; |
-const _EDIT_UPDATE = 1; |
-const _EDIT_ADD = 2; |
-const _EDIT_DELETE = 3; |
+const _kEditLeave = 0; |
+const _kEditUpdate = 1; |
+const _kEditAdd = 2; |
+const _kEditDelete = 3; |
// This starts at the final weight, and walks "backward" by finding |
// the minimum previous weight recursively until the origin of the weight |
// matrix. |
List<int> _spliceOperationsFromEditDistances(List<List<int>> distances) { |
- var i = distances.length - 1; |
- var j = distances[0].length - 1; |
- var current = distances[i][j]; |
- var edits = []; |
+ int i = distances.length - 1; |
+ int j = distances[0].length - 1; |
+ int current = distances[i][j]; |
+ List<int> edits = <int>[]; |
while (i > 0 || j > 0) { |
if (i == 0) { |
- edits.add(_EDIT_ADD); |
+ edits.add(_kEditAdd); |
j--; |
continue; |
} |
if (j == 0) { |
- edits.add(_EDIT_DELETE); |
+ edits.add(_kEditDelete); |
i--; |
continue; |
} |
- var northWest = distances[i - 1][j - 1]; |
- var west = distances[i - 1][j]; |
- var north = distances[i][j - 1]; |
+ int northWest = distances[i - 1][j - 1]; |
+ int west = distances[i - 1][j]; |
+ int north = distances[i][j - 1]; |
- var min = math.min(math.min(west, north), northWest); |
+ int min = math.min(math.min(west, north), northWest); |
if (min == northWest) { |
if (northWest == current) { |
- edits.add(_EDIT_LEAVE); |
+ edits.add(_kEditLeave); |
} else { |
- edits.add(_EDIT_UPDATE); |
+ edits.add(_kEditUpdate); |
current = northWest; |
} |
i--; |
j--; |
} else if (min == west) { |
- edits.add(_EDIT_DELETE); |
+ edits.add(_kEditDelete); |
i--; |
current = west; |
} else { |
- edits.add(_EDIT_ADD); |
+ edits.add(_kEditAdd); |
j--; |
current = north; |
} |
@@ -161,7 +161,7 @@ List<int> _spliceOperationsFromEditDistances(List<List<int>> distances) { |
} |
int _sharedPrefix(List arr1, List arr2, int searchLength) { |
- for (var i = 0; i < searchLength; i++) { |
+ for (int i = 0; i < searchLength; i++) { |
if (arr1[i] != arr2[i]) { |
return i; |
} |
@@ -170,9 +170,9 @@ int _sharedPrefix(List arr1, List arr2, int searchLength) { |
} |
int _sharedSuffix(List arr1, List arr2, int searchLength) { |
- var index1 = arr1.length; |
- var index2 = arr2.length; |
- var count = 0; |
+ int index1 = arr1.length; |
+ int index2 = arr2.length; |
+ int count = 0; |
while (count < searchLength && arr1[--index1] == arr2[--index2]) { |
count++; |
} |
@@ -189,11 +189,10 @@ int _sharedSuffix(List arr1, List arr2, int searchLength) { |
/// p: The length of the old array |
List<ListChangeRecord> calcSplices(List current, int currentStart, |
int currentEnd, List old, int oldStart, int oldEnd) { |
+ int prefixCount = 0; |
+ int suffixCount = 0; |
- var prefixCount = 0; |
- var suffixCount = 0; |
- |
- var minLength = math.min(currentEnd - currentStart, oldEnd - oldStart); |
+ int minLength = math.min(currentEnd - currentStart, oldEnd - oldStart); |
if (currentStart == 0 && oldStart == 0) { |
prefixCount = _sharedPrefix(current, old, minLength); |
} |
@@ -212,27 +211,29 @@ List<ListChangeRecord> calcSplices(List current, int currentStart, |
} |
if (currentStart == currentEnd) { |
- var splice = new ListChangeRecord(current, currentStart); |
+ ListChangeRecord splice = new ListChangeRecord(current, currentStart); |
while (oldStart < oldEnd) { |
splice._removed.add(old[oldStart++]); |
} |
- return [splice ]; |
- } else if (oldStart == oldEnd) |
- return [new ListChangeRecord(current, currentStart, |
- addedCount: currentEnd - currentStart)]; |
- |
- var ops = _spliceOperationsFromEditDistances( |
- _calcEditDistances(current, currentStart, currentEnd, old, oldStart, |
- oldEnd)); |
- |
- ListChangeRecord splice = null; |
- var splices = <ListChangeRecord>[]; |
- var index = currentStart; |
- var oldIndex = oldStart; |
- for (var i = 0; i < ops.length; i++) { |
- switch(ops[i]) { |
- case _EDIT_LEAVE: |
+ return [splice]; |
+ } else if (oldStart == oldEnd) { |
+ return [ |
+ new ListChangeRecord(current, currentStart, |
+ addedCount: currentEnd - currentStart) |
+ ]; |
+ } |
+ |
+ List<int> ops = _spliceOperationsFromEditDistances(_calcEditDistances( |
+ current, currentStart, currentEnd, old, oldStart, oldEnd)); |
+ |
+ ListChangeRecord splice; |
+ List<ListChangeRecord> splices = <ListChangeRecord>[]; |
+ int index = currentStart; |
+ int oldIndex = oldStart; |
+ for (int i = 0; i < ops.length; i++) { |
+ switch (ops[i]) { |
+ case _kEditLeave: |
if (splice != null) { |
splices.add(splice); |
splice = null; |
@@ -241,7 +242,7 @@ List<ListChangeRecord> calcSplices(List current, int currentStart, |
index++; |
oldIndex++; |
break; |
- case _EDIT_UPDATE: |
+ case _kEditUpdate: |
if (splice == null) splice = new ListChangeRecord(current, index); |
splice._addedCount++; |
@@ -250,13 +251,13 @@ List<ListChangeRecord> calcSplices(List current, int currentStart, |
splice._removed.add(old[oldIndex]); |
oldIndex++; |
break; |
- case _EDIT_ADD: |
+ case _kEditAdd: |
if (splice == null) splice = new ListChangeRecord(current, index); |
splice._addedCount++; |
index++; |
break; |
- case _EDIT_DELETE: |
+ case _kEditDelete: |
if (splice == null) splice = new ListChangeRecord(current, index); |
splice._removed.add(old[oldIndex]); |
@@ -273,25 +274,27 @@ int _intersect(int start1, int end1, int start2, int end2) => |
math.min(end1, end2) - math.max(start1, start2); |
void _mergeSplice(List<ListChangeRecord> splices, ListChangeRecord record) { |
- var splice = new ListChangeRecord(record.object, record.index, |
+ ListChangeRecord splice = new ListChangeRecord(record.object, record.index, |
removed: record._removed.toList(), addedCount: record.addedCount); |
- var inserted = false; |
- var insertionOffset = 0; |
+ bool inserted = false; |
+ int insertionOffset = 0; |
// I think the way this works is: |
// - the loop finds where the merge should happen |
// - it applies the merge in a particular splice |
// - then continues and updates the subsequent splices with any offset diff. |
- for (var i = 0; i < splices.length; i++) { |
- final current = splices[i]; |
+ for (int i = 0; i < splices.length; i++) { |
+ final ListChangeRecord current = splices[i]; |
current._index += insertionOffset; |
if (inserted) continue; |
- var intersectCount = _intersect( |
- splice.index, splice.index + splice.removed.length, |
- current.index, current.index + current.addedCount); |
+ int intersectCount = _intersect( |
+ splice.index, |
+ splice.index + splice.removed.length, |
+ current.index, |
+ current.index + current.addedCount); |
if (intersectCount >= 0) { |
// Merge the two splices |
@@ -302,19 +305,19 @@ void _mergeSplice(List<ListChangeRecord> splices, ListChangeRecord record) { |
insertionOffset -= current.addedCount - current.removed.length; |
splice._addedCount += current.addedCount - intersectCount; |
- var deleteCount = splice.removed.length + |
- current.removed.length - intersectCount; |
+ int deleteCount = |
+ splice.removed.length + current.removed.length - intersectCount; |
if (splice.addedCount == 0 && deleteCount == 0) { |
// merged splice is a noop. discard. |
inserted = true; |
} else { |
- var removed = current._removed; |
+ List removed = current._removed; |
if (splice.index < current.index) { |
// some prefix of splice.removed is prepended to current.removed. |
- removed.insertAll(0, |
- splice.removed.getRange(0, current.index - splice.index)); |
+ removed.insertAll( |
+ 0, splice.removed.getRange(0, current.index - splice.index)); |
} |
if (splice.index + splice.removed.length > |
@@ -339,7 +342,7 @@ void _mergeSplice(List<ListChangeRecord> splices, ListChangeRecord record) { |
splices.insert(i, splice); |
i++; |
- var offset = splice.addedCount - splice.removed.length; |
+ int offset = splice.addedCount - splice.removed.length; |
current._index += offset; |
insertionOffset += offset; |
} |
@@ -348,11 +351,10 @@ void _mergeSplice(List<ListChangeRecord> splices, ListChangeRecord record) { |
if (!inserted) splices.add(splice); |
} |
-List<ListChangeRecord> _createInitialSplices(List<Object> list, |
- List<ListChangeRecord> records) { |
- |
- var splices = <ListChangeRecord>[]; |
- for (var record in records) { |
+List<ListChangeRecord> _createInitialSplices( |
+ List<Object> list, List<ListChangeRecord> records) { |
+ List<ListChangeRecord> splices = []; |
+ for (ListChangeRecord record in records) { |
_mergeSplice(splices, record); |
} |
return splices; |
@@ -372,19 +374,23 @@ List<ListChangeRecord> _createInitialSplices(List<Object> list, |
/// Here, we inserted some records and then removed some of them. |
/// If someone processed these records naively, they would "play back" the |
/// insert incorrectly, because those items will be shifted. |
-List<ListChangeRecord> projectListSplices(List list, |
- List<ListChangeRecord> records) { |
+List<ListChangeRecord> projectListSplices( |
+ List<Object> list, List<ListChangeRecord> records) { |
if (records.length <= 1) return records; |
- var splices = []; |
- for (var splice in _createInitialSplices(list, records)) { |
+ List<ListChangeRecord> splices = <ListChangeRecord>[]; |
+ for (ListChangeRecord splice in _createInitialSplices(list, records)) { |
if (splice.addedCount == 1 && splice.removed.length == 1) { |
if (splice.removed[0] != list[splice.index]) splices.add(splice); |
continue; |
} |
- splices.addAll(calcSplices(list, splice.index, |
- splice.index + splice.addedCount, splice._removed, 0, |
+ splices.addAll(calcSplices( |
+ list, |
+ splice.index, |
+ splice.index + splice.addedCount, |
+ splice._removed, |
+ 0, |
splice.removed.length)); |
} |