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 | |
20 sc = new StreamController(onListen: send, onResume: send); | |
21 | |
22 f(s) async { | |
23 var r = 0; | |
24 await for (var i in s) { | |
25 r += await new Future.delayed(new Duration(milliseconds: 10), () => i); | |
26 } | |
27 return r; | |
28 } | |
29 | |
30 asyncStart(); | |
31 f(sc.stream).then((v) { | |
32 Expect.equals(10, v); | |
33 asyncEnd(); | |
34 }); | |
35 } | |
OLD | NEW |