Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import 'dart:async';
- Future<int> sumStream(Stream<int> stream) async {
- var sum = 0;
- try {
- await for (var value in stream) {
- sum += value;
- }
- } catch (error) {
- return -1;
- }
- return sum;
- }
- Stream<int> countStream(int to) async* {
- for (int i = 1; i <= to; i++) {
- if (i == 4) {
- throw "Whoops!"; // Intentional error
- } else {
- yield i;
- }
- }
- }
- main() async {
- var stream = countStream(10);
- var sum = await sumStream(stream);
- print(sum); // -1
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement