| OLD | NEW |
| 1 // Copyright (c) 2013, 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 library observe.src.list_diff; | 5 library observable.src.list_diff; |
| 6 | 6 |
| 7 import 'dart:collection' show UnmodifiableListView; |
| 7 import 'dart:math' as math; | 8 import 'dart:math' as math; |
| 8 import 'dart:collection' show UnmodifiableListView; | 9 |
| 9 import 'change_record.dart' show ChangeRecord; | 10 import 'change_record.dart' show ChangeRecord; |
| 10 | 11 |
| 11 /// A summary of an individual change to a [List]. | 12 /// A summary of an individual change to a [List]. |
| 12 /// | 13 /// |
| 13 /// Each delta represents that at the [index], [removed] sequence of items were | 14 /// Each delta represents that at the [index], [removed] sequence of items were |
| 14 /// removed, and counting forward from [index], [addedCount] items were added. | 15 /// removed, and counting forward from [index], [addedCount] items were added. |
| 15 class ListChangeRecord extends ChangeRecord { | 16 class ListChangeRecord /* TODO(tvolkert): remove */ extends ChangeRecord { |
| 16 /// The list that changed. | 17 /// The list that changed. |
| 17 final List object; | 18 final List object; |
| 18 | 19 |
| 19 /// The index of the change. | 20 /// The index of the change. |
| 20 int get index => _index; | 21 int get index => _index; |
| 21 | 22 |
| 22 /// The items removed, if any. Otherwise this will be an empty list. | 23 /// The items removed, if any. Otherwise this will be an empty list. |
| 23 List get removed => _unmodifiableRemoved; | 24 List get removed => _unmodifiableRemoved; |
| 24 UnmodifiableListView _unmodifiableRemoved; | 25 UnmodifiableListView _unmodifiableRemoved; |
| 25 | 26 |
| 26 /// Mutable version of [removed], used during the algorithms as they are | 27 /// Mutable version of [removed], used during the algorithms as they are |
| 27 /// constructing the object. | 28 /// constructing the object. |
| 28 List _removed; | 29 List _removed; |
| 29 | 30 |
| 30 /// The number of items added. | 31 /// The number of items added. |
| 31 int get addedCount => _addedCount; | 32 int get addedCount => _addedCount; |
| 32 | 33 |
| 33 // Note: conceptually these are final, but for convenience we increment it as | 34 // Note: conceptually these are final, but for convenience we increment it as |
| 34 // we build the object. It will be "frozen" by the time it is returned the the | 35 // we build the object. It will be "frozen" by the time it is returned the the |
| 35 // user. | 36 // user. |
| 36 int _index, _addedCount; | 37 int _index, _addedCount; |
| 37 | 38 |
| 38 ListChangeRecord._(this.object, this._index, removed, this._addedCount) | 39 ListChangeRecord._(this.object, this._index, List removed, this._addedCount) |
| 39 : _removed = removed, | 40 : _removed = removed, |
| 40 _unmodifiableRemoved = new UnmodifiableListView(removed); | 41 _unmodifiableRemoved = new UnmodifiableListView(removed); |
| 41 | 42 |
| 42 factory ListChangeRecord(List object, int index, | 43 factory ListChangeRecord(List object, int index, |
| 43 {List removed, int addedCount}) { | 44 {List removed, int addedCount}) { |
| 44 | |
| 45 if (removed == null) removed = []; | 45 if (removed == null) removed = []; |
| 46 if (addedCount == null) addedCount = 0; | 46 if (addedCount == null) addedCount = 0; |
| 47 return new ListChangeRecord._(object, index, removed, addedCount); | 47 return new ListChangeRecord._(object, index, removed, addedCount); |
| 48 } | 48 } |
| 49 | 49 |
| 50 /// Returns true if the provided index was changed by this operation. | 50 /// Returns true if the provided [ref] index was changed by this operation. |
| 51 bool indexChanged(key) { | 51 bool indexChanged(int ref) { |
| 52 // If key isn't an int, or before the index, then it wasn't changed. | 52 // If ref is before the index, then it wasn't changed. |
| 53 if (key is! int || key < index) return false; | 53 if (ref < index) return false; |
| 54 | 54 |
| 55 // If this was a shift operation, anything after index is changed. | 55 // If this was a shift operation, anything after index is changed. |
| 56 if (addedCount != removed.length) return true; | 56 if (addedCount != removed.length) return true; |
| 57 | 57 |
| 58 // Otherwise, anything in the update range was changed. | 58 // Otherwise, anything in the update range was changed. |
| 59 return key < index + addedCount; | 59 return ref < index + addedCount; |
| 60 } | 60 } |
| 61 | 61 |
| 62 String toString() => '#<ListChangeRecord index: $index, ' | 62 String toString() => '#<ListChangeRecord index: $index, ' |
| 63 'removed: $removed, addedCount: $addedCount>'; | 63 'removed: $removed, addedCount: $addedCount>'; |
| 64 } | 64 } |
| 65 | 65 |
| 66 // Note: This function is *based* on the computation of the Levenshtein | 66 // Note: This function is *based* on the computation of the Levenshtein |
| 67 // "edit" distance. The one change is that "updates" are treated as two | 67 // "edit" distance. The one change is that "updates" are treated as two |
| 68 // edits - not one. With List splices, an update is really a delete | 68 // edits - not one. With List splices, an update is really a delete |
| 69 // followed by an add. By retaining this, we optimize for "keeping" the | 69 // followed by an add. By retaining this, we optimize for "keeping" the |
| 70 // maximum array items in the original array. For example: | 70 // maximum array items in the original array. For example: |
| 71 // | 71 // |
| 72 // 'xxxx123' -> '123yyyy' | 72 // 'xxxx123' -> '123yyyy' |
| 73 // | 73 // |
| 74 // With 1-edit updates, the shortest path would be just to update all seven | 74 // With 1-edit updates, the shortest path would be just to update all seven |
| 75 // characters. With 2-edit updates, we delete 4, leave 3, and add 4. This | 75 // characters. With 2-edit updates, we delete 4, leave 3, and add 4. This |
| 76 // leaves the substring '123' intact. | 76 // leaves the substring '123' intact. |
| 77 List<List<int>> _calcEditDistances(List current, int currentStart, | 77 List<List<int>> _calcEditDistances(List current, int currentStart, |
| 78 int currentEnd, List old, int oldStart, int oldEnd) { | 78 int currentEnd, List old, int oldStart, int oldEnd) { |
| 79 // "Deletion" columns | 79 // "Deletion" columns |
| 80 var rowCount = oldEnd - oldStart + 1; | 80 int rowCount = oldEnd - oldStart + 1; |
| 81 var columnCount = currentEnd - currentStart + 1; | 81 int columnCount = currentEnd - currentStart + 1; |
| 82 var distances = new List(rowCount); | 82 List<List<int>> distances = new List<List<int>>(rowCount); |
| 83 | 83 |
| 84 // "Addition" rows. Initialize null column. | 84 // "Addition" rows. Initialize null column. |
| 85 for (var i = 0; i < rowCount; i++) { | 85 for (int i = 0; i < rowCount; i++) { |
| 86 distances[i] = new List(columnCount); | 86 distances[i] = new List(columnCount); |
| 87 distances[i][0] = i; | 87 distances[i][0] = i; |
| 88 } | 88 } |
| 89 | 89 |
| 90 // Initialize null row | 90 // Initialize null row |
| 91 for (var j = 0; j < columnCount; j++) { | 91 for (int j = 0; j < columnCount; j++) { |
| 92 distances[0][j] = j; | 92 distances[0][j] = j; |
| 93 } | 93 } |
| 94 | 94 |
| 95 for (var i = 1; i < rowCount; i++) { | 95 for (int i = 1; i < rowCount; i++) { |
| 96 for (var j = 1; j < columnCount; j++) { | 96 for (int j = 1; j < columnCount; j++) { |
| 97 if (old[oldStart + i - 1] == current[currentStart + j - 1]) { | 97 if (old[oldStart + i - 1] == current[currentStart + j - 1]) { |
| 98 distances[i][j] = distances[i - 1][j - 1]; | 98 distances[i][j] = distances[i - 1][j - 1]; |
| 99 } else { | 99 } else { |
| 100 var north = distances[i - 1][j] + 1; | 100 int north = distances[i - 1][j] + 1; |
| 101 var west = distances[i][j - 1] + 1; | 101 int west = distances[i][j - 1] + 1; |
| 102 distances[i][j] = math.min(north, west); | 102 distances[i][j] = math.min(north, west); |
| 103 } | 103 } |
| 104 } | 104 } |
| 105 } | 105 } |
| 106 | 106 |
| 107 return distances; | 107 return distances; |
| 108 } | 108 } |
| 109 | 109 |
| 110 const _EDIT_LEAVE = 0; | 110 const _kEditLeave = 0; |
| 111 const _EDIT_UPDATE = 1; | 111 const _kEditUpdate = 1; |
| 112 const _EDIT_ADD = 2; | 112 const _kEditAdd = 2; |
| 113 const _EDIT_DELETE = 3; | 113 const _kEditDelete = 3; |
| 114 | 114 |
| 115 // This starts at the final weight, and walks "backward" by finding | 115 // This starts at the final weight, and walks "backward" by finding |
| 116 // the minimum previous weight recursively until the origin of the weight | 116 // the minimum previous weight recursively until the origin of the weight |
| 117 // matrix. | 117 // matrix. |
| 118 List<int> _spliceOperationsFromEditDistances(List<List<int>> distances) { | 118 List<int> _spliceOperationsFromEditDistances(List<List<int>> distances) { |
| 119 var i = distances.length - 1; | 119 int i = distances.length - 1; |
| 120 var j = distances[0].length - 1; | 120 int j = distances[0].length - 1; |
| 121 var current = distances[i][j]; | 121 int current = distances[i][j]; |
| 122 var edits = []; | 122 List<int> edits = <int>[]; |
| 123 while (i > 0 || j > 0) { | 123 while (i > 0 || j > 0) { |
| 124 if (i == 0) { | 124 if (i == 0) { |
| 125 edits.add(_EDIT_ADD); | 125 edits.add(_kEditAdd); |
| 126 j--; | 126 j--; |
| 127 continue; | 127 continue; |
| 128 } | 128 } |
| 129 if (j == 0) { | 129 if (j == 0) { |
| 130 edits.add(_EDIT_DELETE); | 130 edits.add(_kEditDelete); |
| 131 i--; | 131 i--; |
| 132 continue; | 132 continue; |
| 133 } | 133 } |
| 134 var northWest = distances[i - 1][j - 1]; | 134 int northWest = distances[i - 1][j - 1]; |
| 135 var west = distances[i - 1][j]; | 135 int west = distances[i - 1][j]; |
| 136 var north = distances[i][j - 1]; | 136 int north = distances[i][j - 1]; |
| 137 | 137 |
| 138 var min = math.min(math.min(west, north), northWest); | 138 int min = math.min(math.min(west, north), northWest); |
| 139 | 139 |
| 140 if (min == northWest) { | 140 if (min == northWest) { |
| 141 if (northWest == current) { | 141 if (northWest == current) { |
| 142 edits.add(_EDIT_LEAVE); | 142 edits.add(_kEditLeave); |
| 143 } else { | 143 } else { |
| 144 edits.add(_EDIT_UPDATE); | 144 edits.add(_kEditUpdate); |
| 145 current = northWest; | 145 current = northWest; |
| 146 } | 146 } |
| 147 i--; | 147 i--; |
| 148 j--; | 148 j--; |
| 149 } else if (min == west) { | 149 } else if (min == west) { |
| 150 edits.add(_EDIT_DELETE); | 150 edits.add(_kEditDelete); |
| 151 i--; | 151 i--; |
| 152 current = west; | 152 current = west; |
| 153 } else { | 153 } else { |
| 154 edits.add(_EDIT_ADD); | 154 edits.add(_kEditAdd); |
| 155 j--; | 155 j--; |
| 156 current = north; | 156 current = north; |
| 157 } | 157 } |
| 158 } | 158 } |
| 159 | 159 |
| 160 return edits.reversed.toList(); | 160 return edits.reversed.toList(); |
| 161 } | 161 } |
| 162 | 162 |
| 163 int _sharedPrefix(List arr1, List arr2, int searchLength) { | 163 int _sharedPrefix(List arr1, List arr2, int searchLength) { |
| 164 for (var i = 0; i < searchLength; i++) { | 164 for (int i = 0; i < searchLength; i++) { |
| 165 if (arr1[i] != arr2[i]) { | 165 if (arr1[i] != arr2[i]) { |
| 166 return i; | 166 return i; |
| 167 } | 167 } |
| 168 } | 168 } |
| 169 return searchLength; | 169 return searchLength; |
| 170 } | 170 } |
| 171 | 171 |
| 172 int _sharedSuffix(List arr1, List arr2, int searchLength) { | 172 int _sharedSuffix(List arr1, List arr2, int searchLength) { |
| 173 var index1 = arr1.length; | 173 int index1 = arr1.length; |
| 174 var index2 = arr2.length; | 174 int index2 = arr2.length; |
| 175 var count = 0; | 175 int count = 0; |
| 176 while (count < searchLength && arr1[--index1] == arr2[--index2]) { | 176 while (count < searchLength && arr1[--index1] == arr2[--index2]) { |
| 177 count++; | 177 count++; |
| 178 } | 178 } |
| 179 return count; | 179 return count; |
| 180 } | 180 } |
| 181 | 181 |
| 182 /// Lacking individual splice mutation information, the minimal set of | 182 /// Lacking individual splice mutation information, the minimal set of |
| 183 /// splices can be synthesized given the previous state and final state of an | 183 /// splices can be synthesized given the previous state and final state of an |
| 184 /// array. The basic approach is to calculate the edit distance matrix and | 184 /// array. The basic approach is to calculate the edit distance matrix and |
| 185 /// choose the shortest path through it. | 185 /// choose the shortest path through it. |
| 186 /// | 186 /// |
| 187 /// Complexity: O(l * p) | 187 /// Complexity: O(l * p) |
| 188 /// l: The length of the current array | 188 /// l: The length of the current array |
| 189 /// p: The length of the old array | 189 /// p: The length of the old array |
| 190 List<ListChangeRecord> calcSplices(List current, int currentStart, | 190 List<ListChangeRecord> calcSplices(List current, int currentStart, |
| 191 int currentEnd, List old, int oldStart, int oldEnd) { | 191 int currentEnd, List old, int oldStart, int oldEnd) { |
| 192 int prefixCount = 0; |
| 193 int suffixCount = 0; |
| 192 | 194 |
| 193 var prefixCount = 0; | 195 int minLength = math.min(currentEnd - currentStart, oldEnd - oldStart); |
| 194 var suffixCount = 0; | |
| 195 | |
| 196 var minLength = math.min(currentEnd - currentStart, oldEnd - oldStart); | |
| 197 if (currentStart == 0 && oldStart == 0) { | 196 if (currentStart == 0 && oldStart == 0) { |
| 198 prefixCount = _sharedPrefix(current, old, minLength); | 197 prefixCount = _sharedPrefix(current, old, minLength); |
| 199 } | 198 } |
| 200 | 199 |
| 201 if (currentEnd == current.length && oldEnd == old.length) { | 200 if (currentEnd == current.length && oldEnd == old.length) { |
| 202 suffixCount = _sharedSuffix(current, old, minLength - prefixCount); | 201 suffixCount = _sharedSuffix(current, old, minLength - prefixCount); |
| 203 } | 202 } |
| 204 | 203 |
| 205 currentStart += prefixCount; | 204 currentStart += prefixCount; |
| 206 oldStart += prefixCount; | 205 oldStart += prefixCount; |
| 207 currentEnd -= suffixCount; | 206 currentEnd -= suffixCount; |
| 208 oldEnd -= suffixCount; | 207 oldEnd -= suffixCount; |
| 209 | 208 |
| 210 if (currentEnd - currentStart == 0 && oldEnd - oldStart == 0) { | 209 if (currentEnd - currentStart == 0 && oldEnd - oldStart == 0) { |
| 211 return const []; | 210 return const []; |
| 212 } | 211 } |
| 213 | 212 |
| 214 if (currentStart == currentEnd) { | 213 if (currentStart == currentEnd) { |
| 215 var splice = new ListChangeRecord(current, currentStart); | 214 ListChangeRecord splice = new ListChangeRecord(current, currentStart); |
| 216 while (oldStart < oldEnd) { | 215 while (oldStart < oldEnd) { |
| 217 splice._removed.add(old[oldStart++]); | 216 splice._removed.add(old[oldStart++]); |
| 218 } | 217 } |
| 219 | 218 |
| 220 return [splice ]; | 219 return [splice]; |
| 221 } else if (oldStart == oldEnd) | 220 } else if (oldStart == oldEnd) { |
| 222 return [new ListChangeRecord(current, currentStart, | 221 return [ |
| 223 addedCount: currentEnd - currentStart)]; | 222 new ListChangeRecord(current, currentStart, |
| 223 addedCount: currentEnd - currentStart) |
| 224 ]; |
| 225 } |
| 224 | 226 |
| 225 var ops = _spliceOperationsFromEditDistances( | 227 List<int> ops = _spliceOperationsFromEditDistances(_calcEditDistances( |
| 226 _calcEditDistances(current, currentStart, currentEnd, old, oldStart, | 228 current, currentStart, currentEnd, old, oldStart, oldEnd)); |
| 227 oldEnd)); | |
| 228 | 229 |
| 229 ListChangeRecord splice = null; | 230 ListChangeRecord splice; |
| 230 var splices = <ListChangeRecord>[]; | 231 List<ListChangeRecord> splices = <ListChangeRecord>[]; |
| 231 var index = currentStart; | 232 int index = currentStart; |
| 232 var oldIndex = oldStart; | 233 int oldIndex = oldStart; |
| 233 for (var i = 0; i < ops.length; i++) { | 234 for (int i = 0; i < ops.length; i++) { |
| 234 switch(ops[i]) { | 235 switch (ops[i]) { |
| 235 case _EDIT_LEAVE: | 236 case _kEditLeave: |
| 236 if (splice != null) { | 237 if (splice != null) { |
| 237 splices.add(splice); | 238 splices.add(splice); |
| 238 splice = null; | 239 splice = null; |
| 239 } | 240 } |
| 240 | 241 |
| 241 index++; | 242 index++; |
| 242 oldIndex++; | 243 oldIndex++; |
| 243 break; | 244 break; |
| 244 case _EDIT_UPDATE: | 245 case _kEditUpdate: |
| 245 if (splice == null) splice = new ListChangeRecord(current, index); | 246 if (splice == null) splice = new ListChangeRecord(current, index); |
| 246 | 247 |
| 247 splice._addedCount++; | 248 splice._addedCount++; |
| 248 index++; | 249 index++; |
| 249 | 250 |
| 250 splice._removed.add(old[oldIndex]); | 251 splice._removed.add(old[oldIndex]); |
| 251 oldIndex++; | 252 oldIndex++; |
| 252 break; | 253 break; |
| 253 case _EDIT_ADD: | 254 case _kEditAdd: |
| 254 if (splice == null) splice = new ListChangeRecord(current, index); | 255 if (splice == null) splice = new ListChangeRecord(current, index); |
| 255 | 256 |
| 256 splice._addedCount++; | 257 splice._addedCount++; |
| 257 index++; | 258 index++; |
| 258 break; | 259 break; |
| 259 case _EDIT_DELETE: | 260 case _kEditDelete: |
| 260 if (splice == null) splice = new ListChangeRecord(current, index); | 261 if (splice == null) splice = new ListChangeRecord(current, index); |
| 261 | 262 |
| 262 splice._removed.add(old[oldIndex]); | 263 splice._removed.add(old[oldIndex]); |
| 263 oldIndex++; | 264 oldIndex++; |
| 264 break; | 265 break; |
| 265 } | 266 } |
| 266 } | 267 } |
| 267 | 268 |
| 268 if (splice != null) splices.add(splice); | 269 if (splice != null) splices.add(splice); |
| 269 return splices; | 270 return splices; |
| 270 } | 271 } |
| 271 | 272 |
| 272 int _intersect(int start1, int end1, int start2, int end2) => | 273 int _intersect(int start1, int end1, int start2, int end2) => |
| 273 math.min(end1, end2) - math.max(start1, start2); | 274 math.min(end1, end2) - math.max(start1, start2); |
| 274 | 275 |
| 275 void _mergeSplice(List<ListChangeRecord> splices, ListChangeRecord record) { | 276 void _mergeSplice(List<ListChangeRecord> splices, ListChangeRecord record) { |
| 276 var splice = new ListChangeRecord(record.object, record.index, | 277 ListChangeRecord splice = new ListChangeRecord(record.object, record.index, |
| 277 removed: record._removed.toList(), addedCount: record.addedCount); | 278 removed: record._removed.toList(), addedCount: record.addedCount); |
| 278 | 279 |
| 279 var inserted = false; | 280 bool inserted = false; |
| 280 var insertionOffset = 0; | 281 int insertionOffset = 0; |
| 281 | 282 |
| 282 // I think the way this works is: | 283 // I think the way this works is: |
| 283 // - the loop finds where the merge should happen | 284 // - the loop finds where the merge should happen |
| 284 // - it applies the merge in a particular splice | 285 // - it applies the merge in a particular splice |
| 285 // - then continues and updates the subsequent splices with any offset diff. | 286 // - then continues and updates the subsequent splices with any offset diff. |
| 286 for (var i = 0; i < splices.length; i++) { | 287 for (int i = 0; i < splices.length; i++) { |
| 287 final current = splices[i]; | 288 final ListChangeRecord current = splices[i]; |
| 288 current._index += insertionOffset; | 289 current._index += insertionOffset; |
| 289 | 290 |
| 290 if (inserted) continue; | 291 if (inserted) continue; |
| 291 | 292 |
| 292 var intersectCount = _intersect( | 293 int intersectCount = _intersect( |
| 293 splice.index, splice.index + splice.removed.length, | 294 splice.index, |
| 294 current.index, current.index + current.addedCount); | 295 splice.index + splice.removed.length, |
| 296 current.index, |
| 297 current.index + current.addedCount); |
| 295 | 298 |
| 296 if (intersectCount >= 0) { | 299 if (intersectCount >= 0) { |
| 297 // Merge the two splices | 300 // Merge the two splices |
| 298 | 301 |
| 299 splices.removeAt(i); | 302 splices.removeAt(i); |
| 300 i--; | 303 i--; |
| 301 | 304 |
| 302 insertionOffset -= current.addedCount - current.removed.length; | 305 insertionOffset -= current.addedCount - current.removed.length; |
| 303 | 306 |
| 304 splice._addedCount += current.addedCount - intersectCount; | 307 splice._addedCount += current.addedCount - intersectCount; |
| 305 var deleteCount = splice.removed.length + | 308 int deleteCount = |
| 306 current.removed.length - intersectCount; | 309 splice.removed.length + current.removed.length - intersectCount; |
| 307 | 310 |
| 308 if (splice.addedCount == 0 && deleteCount == 0) { | 311 if (splice.addedCount == 0 && deleteCount == 0) { |
| 309 // merged splice is a noop. discard. | 312 // merged splice is a noop. discard. |
| 310 inserted = true; | 313 inserted = true; |
| 311 } else { | 314 } else { |
| 312 var removed = current._removed; | 315 List removed = current._removed; |
| 313 | 316 |
| 314 if (splice.index < current.index) { | 317 if (splice.index < current.index) { |
| 315 // some prefix of splice.removed is prepended to current.removed. | 318 // some prefix of splice.removed is prepended to current.removed. |
| 316 removed.insertAll(0, | 319 removed.insertAll( |
| 317 splice.removed.getRange(0, current.index - splice.index)); | 320 0, splice.removed.getRange(0, current.index - splice.index)); |
| 318 } | 321 } |
| 319 | 322 |
| 320 if (splice.index + splice.removed.length > | 323 if (splice.index + splice.removed.length > |
| 321 current.index + current.addedCount) { | 324 current.index + current.addedCount) { |
| 322 // some suffix of splice.removed is appended to current.removed. | 325 // some suffix of splice.removed is appended to current.removed. |
| 323 removed.addAll(splice.removed.getRange( | 326 removed.addAll(splice.removed.getRange( |
| 324 current.index + current.addedCount - splice.index, | 327 current.index + current.addedCount - splice.index, |
| 325 splice.removed.length)); | 328 splice.removed.length)); |
| 326 } | 329 } |
| 327 | 330 |
| 328 splice._removed = removed; | 331 splice._removed = removed; |
| 329 splice._unmodifiableRemoved = current._unmodifiableRemoved; | 332 splice._unmodifiableRemoved = current._unmodifiableRemoved; |
| 330 if (current.index < splice.index) { | 333 if (current.index < splice.index) { |
| 331 splice._index = current.index; | 334 splice._index = current.index; |
| 332 } | 335 } |
| 333 } | 336 } |
| 334 } else if (splice.index < current.index) { | 337 } else if (splice.index < current.index) { |
| 335 // Insert splice here. | 338 // Insert splice here. |
| 336 | 339 |
| 337 inserted = true; | 340 inserted = true; |
| 338 | 341 |
| 339 splices.insert(i, splice); | 342 splices.insert(i, splice); |
| 340 i++; | 343 i++; |
| 341 | 344 |
| 342 var offset = splice.addedCount - splice.removed.length; | 345 int offset = splice.addedCount - splice.removed.length; |
| 343 current._index += offset; | 346 current._index += offset; |
| 344 insertionOffset += offset; | 347 insertionOffset += offset; |
| 345 } | 348 } |
| 346 } | 349 } |
| 347 | 350 |
| 348 if (!inserted) splices.add(splice); | 351 if (!inserted) splices.add(splice); |
| 349 } | 352 } |
| 350 | 353 |
| 351 List<ListChangeRecord> _createInitialSplices(List<Object> list, | 354 List<ListChangeRecord> _createInitialSplices( |
| 352 List<ListChangeRecord> records) { | 355 List<Object> list, List<ListChangeRecord> records) { |
| 353 | 356 List<ListChangeRecord> splices = []; |
| 354 var splices = <ListChangeRecord>[]; | 357 for (ListChangeRecord record in records) { |
| 355 for (var record in records) { | |
| 356 _mergeSplice(splices, record); | 358 _mergeSplice(splices, record); |
| 357 } | 359 } |
| 358 return splices; | 360 return splices; |
| 359 } | 361 } |
| 360 | 362 |
| 361 /// We need to summarize change records. Consumers of these records want to | 363 /// We need to summarize change records. Consumers of these records want to |
| 362 /// apply the batch sequentially, and ensure that they can find inserted | 364 /// apply the batch sequentially, and ensure that they can find inserted |
| 363 /// items by looking at that position in the list. This property does not | 365 /// items by looking at that position in the list. This property does not |
| 364 /// hold in our record-as-you-go records. Consider: | 366 /// hold in our record-as-you-go records. Consider: |
| 365 /// | 367 /// |
| 366 /// var model = toObservable(['a', 'b']); | 368 /// var model = toObservable(['a', 'b']); |
| 367 /// model.removeAt(1); | 369 /// model.removeAt(1); |
| 368 /// model.insertAll(0, ['c', 'd', 'e']); | 370 /// model.insertAll(0, ['c', 'd', 'e']); |
| 369 /// model.removeRange(1, 3); | 371 /// model.removeRange(1, 3); |
| 370 /// model.insert(1, 'f'); | 372 /// model.insert(1, 'f'); |
| 371 /// | 373 /// |
| 372 /// Here, we inserted some records and then removed some of them. | 374 /// Here, we inserted some records and then removed some of them. |
| 373 /// If someone processed these records naively, they would "play back" the | 375 /// If someone processed these records naively, they would "play back" the |
| 374 /// insert incorrectly, because those items will be shifted. | 376 /// insert incorrectly, because those items will be shifted. |
| 375 List<ListChangeRecord> projectListSplices(List list, | 377 List<ListChangeRecord> projectListSplices( |
| 376 List<ListChangeRecord> records) { | 378 List<Object> list, List<ListChangeRecord> records) { |
| 377 if (records.length <= 1) return records; | 379 if (records.length <= 1) return records; |
| 378 | 380 |
| 379 var splices = []; | 381 List<ListChangeRecord> splices = <ListChangeRecord>[]; |
| 380 for (var splice in _createInitialSplices(list, records)) { | 382 for (ListChangeRecord splice in _createInitialSplices(list, records)) { |
| 381 if (splice.addedCount == 1 && splice.removed.length == 1) { | 383 if (splice.addedCount == 1 && splice.removed.length == 1) { |
| 382 if (splice.removed[0] != list[splice.index]) splices.add(splice); | 384 if (splice.removed[0] != list[splice.index]) splices.add(splice); |
| 383 continue; | 385 continue; |
| 384 } | 386 } |
| 385 | 387 |
| 386 splices.addAll(calcSplices(list, splice.index, | 388 splices.addAll(calcSplices( |
| 387 splice.index + splice.addedCount, splice._removed, 0, | 389 list, |
| 390 splice.index, |
| 391 splice.index + splice.addedCount, |
| 392 splice._removed, |
| 393 0, |
| 388 splice.removed.length)); | 394 splice.removed.length)); |
| 389 } | 395 } |
| 390 | 396 |
| 391 return splices; | 397 return splices; |
| 392 } | 398 } |
| OLD | NEW |