| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 import 'dart:async'; | 5 import 'dart:async'; |
| 6 import 'package:observe/observe.dart'; | 6 import 'package:observe/observe.dart'; |
| 7 import 'package:unittest/unittest.dart'; | 7 import 'package:unittest/unittest.dart'; |
| 8 import 'observe_test_utils.dart'; | 8 import 'observe_test_utils.dart'; |
| 9 | 9 |
| 10 main() { | 10 main() { |
| 11 // TODO(jmesserly): need all standard Map API tests. | 11 // TODO(jmesserly): need all standard Map API tests. |
| 12 | 12 |
| 13 StreamSubscription sub; | 13 StreamSubscription sub; |
| 14 | 14 |
| 15 sharedTearDown() { | 15 sharedTearDown() { |
| 16 if (sub != null) { | 16 if (sub != null) { |
| 17 sub.cancel(); | 17 sub.cancel(); |
| 18 sub = null; | 18 sub = null; |
| 19 } | 19 } |
| 20 } | 20 } |
| 21 | 21 |
| 22 group('observe length', () { | 22 group('observe length', () { |
| 23 ObservableMap map; | 23 ObservableMap map; |
| 24 List<ChangeRecord> changes; | 24 List<ChangeRecord> changes; |
| 25 | 25 |
| 26 setUp(() { | 26 setUp(() { |
| 27 map = toObservable({'a': 1, 'b': 2, 'c': 3}); | 27 map = toObservable({'a': 1, 'b': 2, 'c': 3}); |
| 28 changes = null; | 28 changes = null; |
| 29 sub = map.changes.listen((records) { | 29 sub = map.changes.listen((records) { |
| 30 changes = records.where((r) => r.changes(#length)).toList(); | 30 changes = getPropertyChangeRecords(records, #length); |
| 31 }); | 31 }); |
| 32 }); | 32 }); |
| 33 | 33 |
| 34 tearDown(sharedTearDown); | 34 tearDown(sharedTearDown); |
| 35 | 35 |
| 36 observeTest('add item changes length', () { | 36 observeTest('add item changes length', () { |
| 37 map['d'] = 4; | 37 map['d'] = 4; |
| 38 expect(map, {'a': 1, 'b': 2, 'c': 3, 'd': 4}); | 38 expect(map, {'a': 1, 'b': 2, 'c': 3, 'd': 4}); |
| 39 performMicrotaskCheckpoint(); | 39 performMicrotaskCheckpoint(); |
| 40 expectChanges(changes, [_lengthChange]); | 40 expectChanges(changes, [_lengthChange(map, 3, 4)]); |
| 41 }); | 41 }); |
| 42 | 42 |
| 43 observeTest('putIfAbsent changes length', () { | 43 observeTest('putIfAbsent changes length', () { |
| 44 map.putIfAbsent('d', () => 4); | 44 map.putIfAbsent('d', () => 4); |
| 45 expect(map, {'a': 1, 'b': 2, 'c': 3, 'd': 4}); | 45 expect(map, {'a': 1, 'b': 2, 'c': 3, 'd': 4}); |
| 46 performMicrotaskCheckpoint(); | 46 performMicrotaskCheckpoint(); |
| 47 expectChanges(changes, [_lengthChange]); | 47 expectChanges(changes, [_lengthChange(map, 3, 4)]); |
| 48 }); | 48 }); |
| 49 | 49 |
| 50 observeTest('remove changes length', () { | 50 observeTest('remove changes length', () { |
| 51 map.remove('c'); | 51 map.remove('c'); |
| 52 map.remove('a'); | 52 map.remove('a'); |
| 53 expect(map, {'b': 2}); | 53 expect(map, {'b': 2}); |
| 54 performMicrotaskCheckpoint(); | 54 performMicrotaskCheckpoint(); |
| 55 expectChanges(changes, [_lengthChange, _lengthChange]); | 55 expectChanges(changes, [ |
| 56 _lengthChange(map, 3, 2), |
| 57 _lengthChange(map, 2, 1) |
| 58 ]); |
| 56 }); | 59 }); |
| 57 | 60 |
| 58 observeTest('remove non-existent item does not change length', () { | 61 observeTest('remove non-existent item does not change length', () { |
| 59 map.remove('d'); | 62 map.remove('d'); |
| 60 expect(map, {'a': 1, 'b': 2, 'c': 3}); | 63 expect(map, {'a': 1, 'b': 2, 'c': 3}); |
| 61 performMicrotaskCheckpoint(); | 64 performMicrotaskCheckpoint(); |
| 62 expectChanges(changes, null); | 65 expectChanges(changes, null); |
| 63 }); | 66 }); |
| 64 | 67 |
| 65 observeTest('set existing item does not change length', () { | 68 observeTest('set existing item does not change length', () { |
| 66 map['c'] = 9000; | 69 map['c'] = 9000; |
| 67 expect(map, {'a': 1, 'b': 2, 'c': 9000}); | 70 expect(map, {'a': 1, 'b': 2, 'c': 9000}); |
| 68 performMicrotaskCheckpoint(); | 71 performMicrotaskCheckpoint(); |
| 69 expectChanges(changes, []); | 72 expectChanges(changes, []); |
| 70 }); | 73 }); |
| 71 | 74 |
| 72 observeTest('clear changes length', () { | 75 observeTest('clear changes length', () { |
| 73 map.clear(); | 76 map.clear(); |
| 74 expect(map, {}); | 77 expect(map, {}); |
| 75 performMicrotaskCheckpoint(); | 78 performMicrotaskCheckpoint(); |
| 76 expectChanges(changes, [_lengthChange]); | 79 expectChanges(changes, [_lengthChange(map, 3, 0)]); |
| 77 }); | 80 }); |
| 78 }); | 81 }); |
| 79 | 82 |
| 80 group('observe item', () { | 83 group('observe item', () { |
| 81 | 84 |
| 82 ObservableMap map; | 85 ObservableMap map; |
| 83 List<ChangeRecord> changes; | 86 List<ChangeRecord> changes; |
| 84 | 87 |
| 85 setUp(() { | 88 setUp(() { |
| 86 map = toObservable({'a': 1, 'b': 2, 'c': 3}); | 89 map = toObservable({'a': 1, 'b': 2, 'c': 3}); |
| 87 changes = null; | 90 changes = null; |
| 88 sub = map.changes.listen((records) { | 91 sub = map.changes.listen((records) { |
| 89 changes = records.where((r) => r.changes('b')).toList(); | 92 changes = records.where((r) => r is MapChangeRecord && r.key == 'b') |
| 93 .toList(); |
| 90 }); | 94 }); |
| 91 }); | 95 }); |
| 92 | 96 |
| 93 tearDown(sharedTearDown); | 97 tearDown(sharedTearDown); |
| 94 | 98 |
| 95 observeTest('putIfAbsent new item does not change existing item', () { | 99 observeTest('putIfAbsent new item does not change existing item', () { |
| 96 map.putIfAbsent('d', () => 4); | 100 map.putIfAbsent('d', () => 4); |
| 97 expect(map, {'a': 1, 'b': 2, 'c': 3, 'd': 4}); | 101 expect(map, {'a': 1, 'b': 2, 'c': 3, 'd': 4}); |
| 98 performMicrotaskCheckpoint(); | 102 performMicrotaskCheckpoint(); |
| 99 expectChanges(changes, []); | 103 expectChanges(changes, []); |
| 100 }); | 104 }); |
| 101 | 105 |
| 102 observeTest('set item to null', () { | 106 observeTest('set item to null', () { |
| 103 map['b'] = null; | 107 map['b'] = null; |
| 104 expect(map, {'a': 1, 'b': null, 'c': 3}); | 108 expect(map, {'a': 1, 'b': null, 'c': 3}); |
| 105 performMicrotaskCheckpoint(); | 109 performMicrotaskCheckpoint(); |
| 106 expectChanges(changes, [_change('b')]); | 110 expectChanges(changes, [_changeKey('b', 2, null)]); |
| 107 }); | 111 }); |
| 108 | 112 |
| 109 observeTest('set item to value', () { | 113 observeTest('set item to value', () { |
| 110 map['b'] = 777; | 114 map['b'] = 777; |
| 111 expect(map, {'a': 1, 'b': 777, 'c': 3}); | 115 expect(map, {'a': 1, 'b': 777, 'c': 3}); |
| 112 performMicrotaskCheckpoint(); | 116 performMicrotaskCheckpoint(); |
| 113 expectChanges(changes, [_change('b')]); | 117 expectChanges(changes, [_changeKey('b', 2, 777)]); |
| 114 }); | 118 }); |
| 115 | 119 |
| 116 observeTest('putIfAbsent does not change if already there', () { | 120 observeTest('putIfAbsent does not change if already there', () { |
| 117 map.putIfAbsent('b', () => 1234); | 121 map.putIfAbsent('b', () => 1234); |
| 118 expect(map, {'a': 1, 'b': 2, 'c': 3}); | 122 expect(map, {'a': 1, 'b': 2, 'c': 3}); |
| 119 performMicrotaskCheckpoint(); | 123 performMicrotaskCheckpoint(); |
| 120 expectChanges(changes, null); | 124 expectChanges(changes, null); |
| 121 }); | 125 }); |
| 122 | 126 |
| 123 observeTest('change a different item', () { | 127 observeTest('change a different item', () { |
| 124 map['c'] = 9000; | 128 map['c'] = 9000; |
| 125 expect(map, {'a': 1, 'b': 2, 'c': 9000}); | 129 expect(map, {'a': 1, 'b': 2, 'c': 9000}); |
| 126 performMicrotaskCheckpoint(); | 130 performMicrotaskCheckpoint(); |
| 127 expectChanges(changes, []); | 131 expectChanges(changes, []); |
| 128 }); | 132 }); |
| 129 | 133 |
| 130 observeTest('change the item', () { | 134 observeTest('change the item', () { |
| 131 map['b'] = 9001; | 135 map['b'] = 9001; |
| 132 map['b'] = 42; | 136 map['b'] = 42; |
| 133 expect(map, {'a': 1, 'b': 42, 'c': 3}); | 137 expect(map, {'a': 1, 'b': 42, 'c': 3}); |
| 134 performMicrotaskCheckpoint(); | 138 performMicrotaskCheckpoint(); |
| 135 expectChanges(changes, [_change('b'), _change('b')]); | 139 expectChanges(changes, [ |
| 140 _changeKey('b', 2, 9001), |
| 141 _changeKey('b', 9001, 42) |
| 142 ]); |
| 136 }); | 143 }); |
| 137 | 144 |
| 138 observeTest('remove other items', () { | 145 observeTest('remove other items', () { |
| 139 map.remove('a'); | 146 map.remove('a'); |
| 140 expect(map, {'b': 2, 'c': 3}); | 147 expect(map, {'b': 2, 'c': 3}); |
| 141 performMicrotaskCheckpoint(); | 148 performMicrotaskCheckpoint(); |
| 142 expectChanges(changes, []); | 149 expectChanges(changes, []); |
| 143 }); | 150 }); |
| 144 | 151 |
| 145 observeTest('remove the item', () { | 152 observeTest('remove the item', () { |
| 146 map.remove('b'); | 153 map.remove('b'); |
| 147 expect(map, {'a': 1, 'c': 3}); | 154 expect(map, {'a': 1, 'c': 3}); |
| 148 performMicrotaskCheckpoint(); | 155 performMicrotaskCheckpoint(); |
| 149 expectChanges(changes, [_change('b', isRemove: true)]); | 156 expectChanges(changes, [_removeKey('b', 2)]); |
| 150 }); | 157 }); |
| 151 | 158 |
| 152 observeTest('remove and add back', () { | 159 observeTest('remove and add back', () { |
| 153 map.remove('b'); | 160 map.remove('b'); |
| 154 map['b'] = 2; | 161 map['b'] = 2; |
| 155 expect(map, {'a': 1, 'b': 2, 'c': 3}); | 162 expect(map, {'a': 1, 'b': 2, 'c': 3}); |
| 156 performMicrotaskCheckpoint(); | 163 performMicrotaskCheckpoint(); |
| 157 expectChanges(changes, | 164 expectChanges(changes, |
| 158 [_change('b', isRemove: true), _change('b', isInsert: true)]); | 165 [_removeKey('b', 2), _insertKey('b', 2)]); |
| 159 }); | 166 }); |
| 160 }); | 167 }); |
| 161 | 168 |
| 162 observeTest('toString', () { | 169 observeTest('toString', () { |
| 163 var map = toObservable({'a': 1, 'b': 2}); | 170 var map = toObservable({'a': 1, 'b': 2}); |
| 164 expect(map.toString(), '{a: 1, b: 2}'); | 171 expect(map.toString(), '{a: 1, b: 2}'); |
| 165 }); | 172 }); |
| 166 | 173 |
| 167 group('change records', () { | 174 group('change records', () { |
| 168 List<ChangeRecord> records; | 175 List<ChangeRecord> records; |
| (...skipping 30 matching lines...) Expand all Loading... |
| 199 | 206 |
| 200 observeTest('putIfAbsent', () { | 207 observeTest('putIfAbsent', () { |
| 201 map.putIfAbsent('a', () => 42); | 208 map.putIfAbsent('a', () => 42); |
| 202 expect(map, {'a': 1, 'b': 2}); | 209 expect(map, {'a': 1, 'b': 2}); |
| 203 | 210 |
| 204 map.putIfAbsent('c', () => 3); | 211 map.putIfAbsent('c', () => 3); |
| 205 expect(map, {'a': 1, 'b': 2, 'c': 3}); | 212 expect(map, {'a': 1, 'b': 2, 'c': 3}); |
| 206 | 213 |
| 207 performMicrotaskCheckpoint(); | 214 performMicrotaskCheckpoint(); |
| 208 expectChanges(records, [ | 215 expectChanges(records, [ |
| 209 _lengthChange, | 216 _lengthChange(map, 2, 3), |
| 210 _change('c', isInsert: true), | 217 _insertKey('c', 3), |
| 211 ]); | 218 ]); |
| 212 }); | 219 }); |
| 213 | 220 |
| 214 observeTest('[]=', () { | 221 observeTest('[]=', () { |
| 215 map['a'] = 42; | 222 map['a'] = 42; |
| 216 expect(map, {'a': 42, 'b': 2}); | 223 expect(map, {'a': 42, 'b': 2}); |
| 217 | 224 |
| 218 map['c'] = 3; | 225 map['c'] = 3; |
| 219 expect(map, {'a': 42, 'b': 2, 'c': 3}); | 226 expect(map, {'a': 42, 'b': 2, 'c': 3}); |
| 220 | 227 |
| 221 performMicrotaskCheckpoint(); | 228 performMicrotaskCheckpoint(); |
| 222 expectChanges(records, [ | 229 expectChanges(records, [ |
| 223 _change('a'), | 230 _changeKey('a', 1, 42), |
| 224 _lengthChange, | 231 _lengthChange(map, 2, 3), |
| 225 _change('c', isInsert: true) | 232 _insertKey('c', 3) |
| 226 ]); | 233 ]); |
| 227 }); | 234 }); |
| 228 | 235 |
| 229 observeTest('remove', () { | 236 observeTest('remove', () { |
| 230 map.remove('b'); | 237 map.remove('b'); |
| 231 expect(map, {'a': 1}); | 238 expect(map, {'a': 1}); |
| 232 | 239 |
| 233 performMicrotaskCheckpoint(); | 240 performMicrotaskCheckpoint(); |
| 234 expectChanges(records, [ | 241 expectChanges(records, [ |
| 235 _change('b', isRemove: true), | 242 _removeKey('b', 2), |
| 236 _lengthChange, | 243 _lengthChange(map, 2, 1), |
| 237 ]); | 244 ]); |
| 238 }); | 245 }); |
| 239 | 246 |
| 240 observeTest('clear', () { | 247 observeTest('clear', () { |
| 241 map.clear(); | 248 map.clear(); |
| 242 expect(map, {}); | 249 expect(map, {}); |
| 243 | 250 |
| 244 performMicrotaskCheckpoint(); | 251 performMicrotaskCheckpoint(); |
| 245 expectChanges(records, [ | 252 expectChanges(records, [ |
| 246 _change('a', isRemove: true), | 253 _removeKey('a', 1), |
| 247 _change('b', isRemove: true), | 254 _removeKey('b', 2), |
| 248 _lengthChange, | 255 _lengthChange(map, 2, 0), |
| 249 ]); | 256 ]); |
| 250 }); | 257 }); |
| 251 }); | 258 }); |
| 252 } | 259 } |
| 253 | 260 |
| 254 final _lengthChange = new PropertyChangeRecord(#length); | 261 _lengthChange(map, int oldValue, int newValue) => |
| 262 new PropertyChangeRecord(map, #length, oldValue, newValue); |
| 255 | 263 |
| 256 _change(key, {isInsert: false, isRemove: false}) => | 264 _changeKey(key, old, newValue) => new MapChangeRecord(key, old, newValue); |
| 257 new MapChangeRecord(key, isInsert: isInsert, isRemove: isRemove); | 265 |
| 266 _insertKey(key, newValue) => new MapChangeRecord.insert(key, newValue); |
| 267 |
| 268 _removeKey(key, oldValue) => new MapChangeRecord.remove(key, oldValue); |
| OLD | NEW |