Advertisement
Guest User

Untitled

a guest
Aug 2nd, 2015
232
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.49 KB | None | 0 0
  1. import 'dart:async';
  2.  
  3. Future<int> sumStream(Stream<int> stream) async {
  4. var sum = 0;
  5. try {
  6. await for (var value in stream) {
  7. sum += value;
  8. }
  9. } catch (error) {
  10. return -1;
  11. }
  12. return sum;
  13. }
  14.  
  15. Stream<int> countStream(int to) async* {
  16. for (int i = 1; i <= to; i++) {
  17. if (i == 4) {
  18. throw "Whoops!"; // Intentional error
  19. } else {
  20. yield i;
  21. }
  22. }
  23. }
  24.  
  25. main() async {
  26. var stream = countStream(10);
  27. var sum = await sumStream(stream);
  28. print(sum); // -1
  29. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement