[Dart article] Exceptions in streams 2

dart_streams2.dart

import 'dart:async';

void main(List<String> arguments) async {
  Stream<int> stream;

  runZonedGuarded(() {
    stream = getStream();
  }, (e, s) {
    print('PRODUCER ZONE Exception handled: $e, $s');
  });

  runZonedGuarded(() {
    startListener(stream);
  }, (e, s) {
    print('CONSUMER ZONE Exception handled: $e, $s');
  });
}

Stream<int> getStream() {
  final intsController = StreamController<int>.broadcast();
  int i = 42;
  Timer.periodic(Duration(seconds: 1), (timer) {
    i += 1;
    if (i == 46) throw '[Stream] Bad thing happens!';
    intsController.add(i);
  });

  return intsController.stream;
}

void startListener(Stream<int> ints) {
  ints.listen((event) {
    print(event);
    if (event == 44) {
      throw '[Listener] Bad thing happens!';
    }
  });