OLD | NEW |
| (Empty) |
1 // Copyright (c) 2015, 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 import "dart:async"; | |
6 import "package:expect/expect.dart"; | |
7 import "package:async_helper/async_helper.dart"; | |
8 | |
9 main() { | |
10 var sc; | |
11 var i = 0; | |
12 void send() { | |
13 if (i == 5) { | |
14 sc.close(); | |
15 } else { | |
16 sc.add(i++); | |
17 } | |
18 } | |
19 sc = new StreamController(onListen: send, onResume: send); | |
20 | |
21 f(s) async { | |
22 var r = 0; | |
23 await for (var i in s) { | |
24 r += await new Future.delayed(new Duration(milliseconds: 10), () => i); | |
25 } | |
26 return r; | |
27 } | |
28 | |
29 asyncStart(); | |
30 f(sc.stream).then((v) { | |
31 Expect.equals(10, v); | |
32 asyncEnd(); | |
33 }); | |
34 } | |
OLD | NEW |