| OLD | NEW |
| (Empty) |
| 1 library angular.mock.zone_spec; | |
| 2 | |
| 3 import '../_specs.dart'; | |
| 4 import 'dart:async'; | |
| 5 | |
| 6 main() => describe('mock zones', () { | |
| 7 describe('sync', () { | |
| 8 it('should throw an error on scheduleMicrotask', () { | |
| 9 expect(sync(() { | |
| 10 scheduleMicrotask(() => dump("i never run")); | |
| 11 })).toThrow('scheduleMicrotask called from sync function'); | |
| 12 }); | |
| 13 | |
| 14 | |
| 15 it('should throw an error on timer', () { | |
| 16 expect(sync(() { | |
| 17 Timer.run(() => dump("i never run")); | |
| 18 })).toThrow('Timer created from sync function'); | |
| 19 }); | |
| 20 | |
| 21 | |
| 22 it('should throw an error on periodic timer', () { | |
| 23 expect(sync(() { | |
| 24 new Timer.periodic(new Duration(milliseconds: 10), | |
| 25 (_) => dump("i never run")); | |
| 26 })).toThrow('periodic Timer created from sync function'); | |
| 27 }); | |
| 28 }); | |
| 29 | |
| 30 describe('async', () { | |
| 31 it('should run synchronous code', () { | |
| 32 var ran = false; | |
| 33 async(() { ran = true; })(); | |
| 34 expect(ran).toBe(true); | |
| 35 }); | |
| 36 | |
| 37 | |
| 38 it('should run async code', () { | |
| 39 var ran = false; | |
| 40 var thenRan = false; | |
| 41 async(() { | |
| 42 new Future.value('s').then((_) { thenRan = true; }); | |
| 43 expect(thenRan).toBe(false); | |
| 44 microLeap(); | |
| 45 expect(thenRan).toBe(true); | |
| 46 ran = true; | |
| 47 })(); | |
| 48 expect(ran).toBe(true); | |
| 49 }); | |
| 50 | |
| 51 | |
| 52 it('should run async code with scheduleMicrotask', () { | |
| 53 var ran = false; | |
| 54 var thenRan = false; | |
| 55 async(() { | |
| 56 scheduleMicrotask(() { thenRan = true; }); | |
| 57 expect(thenRan).toBe(false); | |
| 58 microLeap(); | |
| 59 expect(thenRan).toBe(true); | |
| 60 ran = true; | |
| 61 })(); | |
| 62 expect(ran).toBe(true); | |
| 63 }); | |
| 64 | |
| 65 | |
| 66 it('should run chained thens', () { | |
| 67 var log = []; | |
| 68 async(() { | |
| 69 new Future.value('s') | |
| 70 .then((_) { log.add('firstThen'); }) | |
| 71 .then((_) { log.add('2ndThen'); }); | |
| 72 expect(log.join(' ')).toEqual(''); | |
| 73 microLeap(); | |
| 74 expect(log.join(' ')).toEqual('firstThen 2ndThen'); | |
| 75 })(); | |
| 76 }); | |
| 77 | |
| 78 | |
| 79 it('shold run futures created in futures', () { | |
| 80 var log = []; | |
| 81 async(() { | |
| 82 new Future.value('s') | |
| 83 .then((_) { | |
| 84 log.add('firstThen'); | |
| 85 new Future.value('t').then((_) { | |
| 86 log.add('2ndThen'); | |
| 87 }); | |
| 88 }); | |
| 89 expect(log.join(' ')).toEqual(''); | |
| 90 microLeap(); | |
| 91 expect(log.join(' ')).toEqual('firstThen 2ndThen'); | |
| 92 })(); | |
| 93 }); | |
| 94 | |
| 95 it('should run all the async calls if asked', () { | |
| 96 var log = []; | |
| 97 async(() { | |
| 98 new Future.value('s') | |
| 99 .then((_) { | |
| 100 log.add('firstThen'); | |
| 101 new Future.value('t').then((_) { | |
| 102 log.add('2ndThen'); | |
| 103 }); | |
| 104 }); | |
| 105 expect(log.join(' ')).toEqual(''); | |
| 106 microLeap(); | |
| 107 expect(log.join(' ')).toEqual('firstThen 2ndThen'); | |
| 108 })(); | |
| 109 }); | |
| 110 | |
| 111 | |
| 112 it('should not complain if you dangle callbacks', () { | |
| 113 async(() { | |
| 114 new Future.value("s").then((_) {}); | |
| 115 })(); | |
| 116 }); | |
| 117 | |
| 118 | |
| 119 it('should complain if you dangle exceptions', () { | |
| 120 expect(() { | |
| 121 async(() { | |
| 122 new Future.value("s").then((_) { | |
| 123 throw ["dangling"]; | |
| 124 }); | |
| 125 })(); | |
| 126 }).toThrow("dangling"); | |
| 127 }); | |
| 128 | |
| 129 | |
| 130 it('should complain if the test throws an exception', () { | |
| 131 expect(() { | |
| 132 async(() { | |
| 133 throw "blah"; | |
| 134 })(); | |
| 135 }).toThrow("blah"); | |
| 136 }); | |
| 137 | |
| 138 | |
| 139 it('should complain if the test throws an exception during async calls', ()
{ | |
| 140 expect(async(() { | |
| 141 new Future.value('s').then((_) { throw "blah then"; }); | |
| 142 microLeap(); | |
| 143 })).toThrow("blah then"); | |
| 144 }); | |
| 145 | |
| 146 it('should throw errors from the microLeap call', async(() { | |
| 147 new Future.value('s').then((_) { throw "blah then 2"; }); | |
| 148 expect(() { | |
| 149 microLeap(); | |
| 150 }).toThrow("blah then 2"); | |
| 151 })); | |
| 152 | |
| 153 describe('timers', () { | |
| 154 it('should not run queued timer on insufficient clock tick', async(() { | |
| 155 bool timerRan = false; | |
| 156 var timer = new Timer(new Duration(milliseconds: 10), | |
| 157 () => timerRan = true); | |
| 158 | |
| 159 clockTick(milliseconds: 9); | |
| 160 expect(timerRan).toBeFalsy(); | |
| 161 | |
| 162 timer.cancel(); | |
| 163 })); | |
| 164 | |
| 165 | |
| 166 it('should run queued zero duration timer on zero tick', async(() { | |
| 167 bool timerRan = false; | |
| 168 Timer.run(() => timerRan = true); | |
| 169 | |
| 170 clockTick(); | |
| 171 expect(timerRan).toBeTruthy(); | |
| 172 })); | |
| 173 | |
| 174 | |
| 175 it('should run queued timer after sufficient clock ticks', async(() { | |
| 176 bool timerRan = false; | |
| 177 new Timer(new Duration(milliseconds: 10), () => timerRan = true); | |
| 178 | |
| 179 clockTick(milliseconds: 9); | |
| 180 expect(timerRan).toBeFalsy(); | |
| 181 clockTick(milliseconds: 1); | |
| 182 expect(timerRan).toBeTruthy(); | |
| 183 })); | |
| 184 | |
| 185 | |
| 186 it('should run queued timer only once', async(() { | |
| 187 int timerRan = 0; | |
| 188 new Timer(new Duration(milliseconds: 10), () => timerRan++); | |
| 189 | |
| 190 clockTick(milliseconds: 10); | |
| 191 expect(timerRan).toBe(1); | |
| 192 clockTick(milliseconds: 10); | |
| 193 expect(timerRan).toBe(1); | |
| 194 clockTick(minutes: 10); | |
| 195 expect(timerRan).toBe(1); | |
| 196 })); | |
| 197 | |
| 198 | |
| 199 it('should run periodic timer', async(() { | |
| 200 int timerRan = 0; | |
| 201 var timer = new Timer.periodic(new Duration(milliseconds: 10), | |
| 202 (_) => timerRan++); | |
| 203 | |
| 204 clockTick(milliseconds: 9); | |
| 205 expect(timerRan).toBe(0); | |
| 206 clockTick(milliseconds: 1); | |
| 207 expect(timerRan).toBe(1); | |
| 208 clockTick(milliseconds: 30); | |
| 209 expect(timerRan).toBe(4); | |
| 210 | |
| 211 timer.cancel(); | |
| 212 })); | |
| 213 | |
| 214 | |
| 215 it('should not run cancelled timer', async(() { | |
| 216 bool timerRan = false; | |
| 217 var timer = new Timer(new Duration(milliseconds: 10), | |
| 218 () => timerRan = true); | |
| 219 | |
| 220 timer.cancel(); | |
| 221 | |
| 222 clockTick(milliseconds: 10); | |
| 223 expect(timerRan).toBeFalsy(); | |
| 224 })); | |
| 225 | |
| 226 | |
| 227 it('should not run cancelled periodic timer', async(() { | |
| 228 bool timerRan = false; | |
| 229 var timer = new Timer.periodic(new Duration(milliseconds: 10), | |
| 230 (_) => timerRan = true); | |
| 231 | |
| 232 timer.cancel(); | |
| 233 | |
| 234 clockTick(milliseconds: 10); | |
| 235 expect(timerRan).toBeFalsy(); | |
| 236 })); | |
| 237 | |
| 238 | |
| 239 it('should be able to cancel periodic timer from callback', async(() { | |
| 240 int timerRan = 0; | |
| 241 var timer = new Timer.periodic(new Duration(milliseconds: 10), | |
| 242 (t) { | |
| 243 timerRan++; | |
| 244 t.cancel(); | |
| 245 }); | |
| 246 | |
| 247 clockTick(milliseconds: 10); | |
| 248 expect(timerRan).toBe(1); | |
| 249 | |
| 250 clockTick(milliseconds: 10); | |
| 251 expect(timerRan).toBe(1); | |
| 252 | |
| 253 timer.cancel(); | |
| 254 })); | |
| 255 | |
| 256 | |
| 257 it('should process micro-tasks before timers', async(() { | |
| 258 var log = []; | |
| 259 | |
| 260 scheduleMicrotask(() => log.add('scheduleMicrotask')); | |
| 261 new Timer(new Duration(milliseconds: 10), | |
| 262 () => log.add('timer')); | |
| 263 var timer = new Timer.periodic(new Duration(milliseconds: 10), | |
| 264 (_) => log.add('periodic_timer')); | |
| 265 | |
| 266 expect(log.join(' ')).toEqual(''); | |
| 267 | |
| 268 clockTick(milliseconds: 10); | |
| 269 | |
| 270 expect(log.join(' ')).toEqual('scheduleMicrotask timer periodic_timer'); | |
| 271 | |
| 272 timer.cancel(); | |
| 273 })); | |
| 274 | |
| 275 | |
| 276 it('should process micro-tasks created in timers before next timers', asyn
c(() { | |
| 277 var log = []; | |
| 278 | |
| 279 scheduleMicrotask(() => log.add('scheduleMicrotask')); | |
| 280 new Timer(new Duration(milliseconds: 10), | |
| 281 () { | |
| 282 log.add('timer'); | |
| 283 scheduleMicrotask(() => log.add('timer_scheduleMicrotask')); | |
| 284 }); | |
| 285 var timer = new Timer.periodic(new Duration(milliseconds: 10), | |
| 286 (_) { | |
| 287 log.add('periodic_timer'); | |
| 288 scheduleMicrotask(() => log.add('periodic_timer_scheduleMicrotask'
)); | |
| 289 }); | |
| 290 | |
| 291 expect(log.join(' ')).toEqual(''); | |
| 292 | |
| 293 clockTick(milliseconds: 10); | |
| 294 expect(log.join(' ')).toEqual('scheduleMicrotask timer timer_scheduleMic
rotask periodic_timer'); | |
| 295 | |
| 296 clockTick(); | |
| 297 expect(log.join(' ')).toEqual('scheduleMicrotask timer timer_scheduleMic
rotask periodic_timer'); | |
| 298 | |
| 299 clockTick(milliseconds: 10); | |
| 300 expect(log.join(' ')).toEqual('scheduleMicrotask timer timer_scheduleMic
rotask periodic_timer periodic_timer_scheduleMicrotask periodic_timer'); | |
| 301 | |
| 302 timer.cancel(); | |
| 303 })); | |
| 304 | |
| 305 | |
| 306 it('should not leak timers between asyncs', () { | |
| 307 var log = []; | |
| 308 | |
| 309 async(() { | |
| 310 var timer = new Timer.periodic(new Duration(milliseconds: 10), | |
| 311 (_) => log.add('periodic_timer')); | |
| 312 new Timer(new Duration(milliseconds: 10), | |
| 313 () => log.add('timer')); | |
| 314 clockTick(milliseconds: 10); | |
| 315 timer.cancel(); | |
| 316 })(); | |
| 317 expect(log.join(' ')).toEqual('periodic_timer timer'); | |
| 318 | |
| 319 async(() { | |
| 320 clockTick(milliseconds: 10); | |
| 321 })(); | |
| 322 expect(log.join(' ')).toEqual('periodic_timer timer'); | |
| 323 }); | |
| 324 | |
| 325 | |
| 326 it('should throw an error on dangling timers', () { | |
| 327 expect(async(() { | |
| 328 new Timer.periodic(new Duration(milliseconds: 10), | |
| 329 (_) => dump("i never run")); | |
| 330 })).toThrow('1 active timer(s) are still in the queue.'); | |
| 331 }); | |
| 332 }); | |
| 333 }); | |
| 334 }); | |
| OLD | NEW |