| 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 // Test merging streams. | 5 // Test merging streams. | 
| 6 library dart.test.stream_from_iterable; | 6 library dart.test.stream_from_iterable; | 
| 7 | 7 | 
| 8 import "dart:async"; | 8 import "dart:async"; | 
| 9 import 'package:unittest/unittest.dart'; | 9 import 'package:test/test.dart'; | 
| 10 | 10 | 
| 11 watchMs(Stopwatch watch) { | 11 watchMs(Stopwatch watch) { | 
| 12   int microsecs = watch.elapsedMicroseconds; | 12   int microsecs = watch.elapsedMicroseconds; | 
| 13   // Give it some slack. The Stopwatch is more precise than the timers. This | 13   // Give it some slack. The Stopwatch is more precise than the timers. This | 
| 14   // means that we sometimes get 3995 microseconds instead of 4+ milliseconds. | 14   // means that we sometimes get 3995 microseconds instead of 4+ milliseconds. | 
| 15   // 200 microseconds should largely account for this discrepancy. | 15   // 200 microseconds should largely account for this discrepancy. | 
| 16   return (microsecs + 200) ~/ 1000; | 16   return (microsecs + 200) ~/ 1000; | 
| 17 } | 17 } | 
| 18 | 18 | 
| 19 main() { | 19 main() { | 
| (...skipping 11 matching lines...) Expand all  Loading... | 
| 31         while (watch2.elapsedMilliseconds < 15) { } | 31         while (watch2.elapsedMilliseconds < 15) { } | 
| 32         // Make sure the stream can be paused when it has overdue events. | 32         // Make sure the stream can be paused when it has overdue events. | 
| 33         // We just busy waited for 15ms, even though the stream is supposed to | 33         // We just busy waited for 15ms, even though the stream is supposed to | 
| 34         // emit events every 5ms. | 34         // emit events every 5ms. | 
| 35         subscription.pause(); | 35         subscription.pause(); | 
| 36         watch.stop(); | 36         watch.stop(); | 
| 37         new Timer(const Duration(milliseconds: 150), () { | 37         new Timer(const Duration(milliseconds: 150), () { | 
| 38           watch.start(); | 38           watch.start(); | 
| 39           subscription.resume(); | 39           subscription.resume(); | 
| 40         }); | 40         }); | 
| 41       } | 41       } | 
| 42     }, onDone: expectAsync(() { })); | 42     }, onDone: expectAsync(() { })); | 
| 43   }); | 43   }); | 
| 44 } | 44 } | 
| OLD | NEW | 
|---|