Stream - 1

main.dart

import 'dart:async';

void main() {
  var streamController = StreamController();
  
  streamController.stream.listen(
    (data) => print('Got eem! $data'),
    onError: (err) => print('Got an error! $err'),
    onDone: () => print('Mission complete!'),
    cancelOnError: false,
  );
  
  streamController.sink.add('Foo');
  streamController.sink.addError('Houston, we have a problem!');
  streamController.sink.close();
}