machinescream

main() async {
  final broadcaster = StreamController.broadcast();
  broadcaster.stream
      .asyncExpand((data) =>
          Stream.fromFuture(Future.delayed(Duration(seconds: 10), () {
            return data;
          })))
      .listen((onData) {
        print(onData);
  });