Index: tests/language/async_star_stream_take_test.dart |
diff --git a/tests/language/asyncstar_concat_test.dart b/tests/language/async_star_stream_take_test.dart |
similarity index 56% |
copy from tests/language/asyncstar_concat_test.dart |
copy to tests/language/async_star_stream_take_test.dart |
index aeb1361cd85fdcc35bf1fd466b161c2462befc4e..095082b0a36bca0fda34f50b2a6a6bcce58da1d4 100644 |
--- a/tests/language/asyncstar_concat_test.dart |
+++ b/tests/language/async_star_stream_take_test.dart |
@@ -2,28 +2,25 @@ |
// for details. All rights reserved. Use of this source code is governed by a |
// BSD-style license that can be found in the LICENSE file. |
+import "dart:async"; |
import "package:expect/expect.dart"; |
import "package:async_helper/async_helper.dart"; |
-range(start, end) async* { |
- for (int i = start; i < end; i++) { |
- yield i; |
- } |
-} |
- |
-concat(a, b) async* { |
- yield* a; |
- yield* b; |
-} |
- |
-test() async { |
- Expect.listEquals([1, 2, 3, 11, 12, 13], |
- await concat(range(1, 4), range(11, 14)).toList()); |
+Stream makeStream(int n) async* { |
+ for (int i = 0; i < n; i++) yield i; |
} |
main() { |
+ f(Stream s) async { |
+ var r = 0; |
+ await for(var v in s.take(5)) r += v; |
+ return r; |
+ } |
+ |
asyncStart(); |
- test().then((_) { |
+ f(makeStream(10)).then((v) { |
+ Expect.equals(10, v); |
asyncEnd(); |
}); |
-} |
+} |
+ |