Skip to content

Instantly share code, notes, and snippets.

@AlexKenbo
Created March 9, 2020 09:13
Show Gist options
  • Save AlexKenbo/e1e51dae93945e576c737cfffe41f204 to your computer and use it in GitHub Desktop.
Save AlexKenbo/e1e51dae93945e576c737cfffe41f204 to your computer and use it in GitHub Desktop.
Error and simple Stream
import 'dart:async';
Future<int> sumStream(Stream<int> stream) async {
var sum = 0;
try {
await for (var value in stream) {
sum += value;
}
} catch (e) {
return -1;
}
return sum;
}
Stream<int> countStream(int to) async* {
for (int i = 1; i <= to; i++) {
if (i == 4) {
throw new Exception('Intentional exception');
} else {
yield i;
}
}
}
main() async {
var stream = countStream(10);
var sum = await sumStream(stream);
print(sum); // -1
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment