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:unittest/unittest.dart'; |
10 | 10 |
11 void runTest(period, maxElapsed, pauseDuration) { | 11 void runTest(period, maxElapsed, pauseDuration) { |
12 Function done = expectAsync(() { }); | 12 Function done = expectAsync(() {}); |
13 | 13 |
14 Stopwatch watch = new Stopwatch()..start(); | 14 Stopwatch watch = new Stopwatch()..start(); |
15 Stream stream = new Stream.periodic(period, (x) => x); | 15 Stream stream = new Stream.periodic(period, (x) => x); |
16 var subscription; | 16 var subscription; |
17 subscription = stream.take(5).listen((i) { | 17 subscription = stream.take(5).listen((i) { |
18 if (watch.elapsed > maxElapsed) { | 18 if (watch.elapsed > maxElapsed) { |
19 // 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 |
20 // if we reached an unreasonable maxElapsed). | 20 // if we reached an unreasonable maxElapsed). |
21 if (maxElapsed > const Duration(seconds: 2)) { | 21 if (maxElapsed > const Duration(seconds: 2)) { |
22 // Give up. | 22 // Give up. |
(...skipping 13 matching lines...) Expand all Loading... |
36 new Timer(pauseDuration, () { | 36 new Timer(pauseDuration, () { |
37 watch.start(); | 37 watch.start(); |
38 subscription.resume(); | 38 subscription.resume(); |
39 }); | 39 }); |
40 } | 40 } |
41 }, onDone: done); | 41 }, onDone: done); |
42 } | 42 } |
43 | 43 |
44 main() { | 44 main() { |
45 test("stream-periodic4", () { | 45 test("stream-periodic4", () { |
46 runTest(const Duration(milliseconds: 2), | 46 runTest(const Duration(milliseconds: 2), const Duration(milliseconds: 8), |
47 const Duration(milliseconds: 8), | 47 const Duration(milliseconds: 10)); |
48 const Duration(milliseconds: 10)); | |
49 }); | 48 }); |
50 } | 49 } |
OLD | NEW |