OLD | NEW |
(Empty) | |
| 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 |
| 3 // BSD-style license that can be found in the LICENSE file. |
| 4 |
| 5 // Test merging streams. |
| 6 library dart.test.stream_from_iterable; |
| 7 |
| 8 import "dart:async"; |
| 9 import 'package:unittest/unittest.dart'; |
| 10 |
| 11 void runTest(period, maxElapsed, pauseDuration) { |
| 12 Function done = expectAsync(() { }); |
| 13 |
| 14 Stopwatch watch = new Stopwatch()..start(); |
| 15 Stream stream = new Stream.periodic(period, (x) => x); |
| 16 var subscription; |
| 17 subscription = stream.take(5).listen((i) { |
| 18 if (watch.elapsed > maxElapsed) { |
| 19 // Test failed in this configuration. Try with more time (or give up |
| 20 // if we reached an unreasonable maxElapsed). |
| 21 if (maxElapsed > const Duration(seconds: 2)) { |
| 22 // Give up. |
| 23 expect(true, false); |
| 24 } else { |
| 25 subscription.cancel(); |
| 26 // Call 'done' ourself, since it won't be invoked in the onDone handler. |
| 27 runTest(period * 2, maxElapsed * 2, pauseDuration * 2); |
| 28 done(); |
| 29 return; |
| 30 } |
| 31 } |
| 32 watch.reset(); |
| 33 if (i == 2) { |
| 34 subscription.pause(); |
| 35 watch.stop(); |
| 36 new Timer(pauseDuration, () { |
| 37 watch.start(); |
| 38 subscription.resume(); |
| 39 }); |
| 40 } |
| 41 }, onDone: done); |
| 42 } |
| 43 |
| 44 main() { |
| 45 test("stream-periodic4", () { |
| 46 runTest(const Duration(milliseconds: 2), |
| 47 const Duration(milliseconds: 8), |
| 48 const Duration(milliseconds: 10)); |
| 49 }); |
| 50 } |
OLD | NEW |