| 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 '../../../pkg/unittest/lib/unittest.dart'; | 9 import '../../../pkg/unittest/lib/unittest.dart'; |
| 10 | 10 |
| 11 int iteration = 0; | |
| 12 | |
| 13 void runTest(period, maxElapsed, pauseDuration) { | 11 void runTest(period, maxElapsed, pauseDuration) { |
| 14 print("Iteration: $iteration"); | |
| 15 var myIteration = iteration; | |
| 16 iteration++; | |
| 17 | |
| 18 Function done = expectAsync0(() { }); | 12 Function done = expectAsync0(() { }); |
| 19 | 13 |
| 20 Stopwatch watch = new Stopwatch()..start(); | 14 Stopwatch watch = new Stopwatch()..start(); |
| 21 Stream stream = new Stream.periodic(period, (x) => x); | 15 Stream stream = new Stream.periodic(period, (x) => x); |
| 22 var subscription; | 16 var subscription; |
| 23 subscription = stream.take(5).listen((i) { | 17 subscription = stream.take(5).listen((i) { |
| 24 if (watch.elapsed > maxElapsed) { | 18 if (watch.elapsed > maxElapsed) { |
| 25 // Test failed in this configuration. Try with more time (or give up | 19 // Test failed in this configuration. Try with more time (or give up |
| 26 // if we reached an unreasonable maxElapsed). | 20 // if we reached an unreasonable maxElapsed). |
| 27 if (maxElapsed > const Duration(seconds: 2)) { | 21 if (maxElapsed > const Duration(seconds: 2)) { |
| 28 // Give up. | 22 // Give up. |
| 29 expect(true, false); | 23 expect(true, false); |
| 30 } else { | 24 } else { |
| 31 subscription.cancel(); | 25 subscription.cancel(); |
| 32 print("Cancelling subscription of iteration: $myIteration"); | |
| 33 // Call 'done' ourself, since it won't be invoked in the onDone handler. | 26 // Call 'done' ourself, since it won't be invoked in the onDone handler. |
| 34 runTest(period * 2, maxElapsed * 2, pauseDuration * 2); | 27 runTest(period * 2, maxElapsed * 2, pauseDuration * 2); |
| 35 print("Invoking done of iteration inside listener: $myIteration"); | |
| 36 done(); | 28 done(); |
| 37 return; | 29 return; |
| 38 } | 30 } |
| 39 } | 31 } |
| 40 watch.reset(); | 32 watch.reset(); |
| 41 if (i == 2) { | 33 if (i == 2) { |
| 42 subscription.pause(); | 34 subscription.pause(); |
| 43 watch.stop(); | 35 watch.stop(); |
| 44 new Timer(pauseDuration, () { | 36 new Timer(pauseDuration, () { |
| 45 watch.start(); | 37 watch.start(); |
| 46 subscription.resume(); | 38 subscription.resume(); |
| 47 }); | 39 }); |
| 48 } | 40 } |
| 49 }, onDone: () { | 41 }, onDone: done); |
| 50 print("Invoking done of iteration: $myIteration"); | |
| 51 done(); | |
| 52 }); | |
| 53 } | 42 } |
| 54 | 43 |
| 55 main() { | 44 main() { |
| 56 test("stream-periodic4", () { | 45 test("stream-periodic4", () { |
| 57 runTest(const Duration(milliseconds: 2), | 46 runTest(const Duration(milliseconds: 2), |
| 58 const Duration(milliseconds: 8), | 47 const Duration(milliseconds: 8), |
| 59 const Duration(milliseconds: 10)); | 48 const Duration(milliseconds: 10)); |
| 60 }); | 49 }); |
| 61 } | 50 } |
| OLD | NEW |