Created
March 9, 2020 09:11
-
-
Save AlexKenbo/7144e06a2071d6e6fc60f9727fc9b153 to your computer and use it in GitHub Desktop.
Future and Stream
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import 'dart:async'; | |
Future<int> sumStream(Stream<int> stream) async { | |
var sum = 0; | |
await for (var value in stream) { | |
sum += value; | |
} | |
return sum; | |
} | |
Stream<int> countStream(int to) async* { | |
for (int i = 1; i <= to; i++) { | |
yield i; | |
} | |
} | |
main() async { | |
var stream = countStream(10); | |
var sum = await sumStream(stream); | |
print(sum); // 55 | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment