无法使用异步接收的数据更新BLoC状态

import 'dart:async';

class MyBloc {
  final _myStreamController = StreamController<String>();

  Stream<String> get myStream => _myStreamController.stream;

  void dispose() {
    _myStreamController.close();
  }
}

class MyBloc {
  // ...

  void fetchData() async {
    try {
      // 执行异步操作，比如从网络请求数据
      String data = await fetchDataFromServer();

      // 将数据添加到Stream中
      _myStreamController.add(data);
    } catch (error) {
      // 处理错误情况
      _myStreamController.addError(error);
    }
  }

  // ...
}

class MyWidget extends StatelessWidget {
  final MyBloc myBloc = MyBloc();

  @override
  Widget build(BuildContext context) {
    return StreamBuilder<String>(
      stream: myBloc.myStream,
      builder: (context, snapshot) {
        if (snapshot.hasData) {
          // 更新UI状态
          return Text(snapshot.data);
        } else if (snapshot.hasError) {
          // 处理错误情况
          return Text('Error: ${snapshot.error}');
        }

        // 初始状态或正在加载数据时显示的UI
        return CircularProgressIndicator();
      },
    );
  }
}