Exemplo stream

stream_exemplo.dart

import 'dart:async';

void main() {
  
  escutarDeepLinks().listen((e) {
    print(e);
  }, onError: (error) {
    print('deu erro vei. $error');
  });
    
}

Stream escutarDeepLinks() {
  final controller = StreamController<String>();
  
  controller.add("codando");
  controller.add("tv");
  
  Future.delayed(Duration(seconds: 1), () {
    controller.add("emitindo depois de 1s");
  }); 
  
  Future.delayed(Duration(milliseconds: 1500), () {
    controller.addError(Exception('aqui :('));
  });
    
 
  return controller.stream;
}