在颤动中使用StreamBuilder显示来自购物车的流

StreamController<List<Product>> _cartController = StreamController<List<Product>>();
Stream<List<Product>> get cartStream => _cartController.stream;

void addToCart(Product product) {
  // 添加商品到购物车
  _cart.add(product);
  // 发送购物车更新事件
  _cartController.add(_cart.toList());
}

void removeFromCart(Product product) {
  // 从购物车中移除商品
  _cart.remove(product);
  // 发送购物车更新事件
  _cartController.add(_cart.toList());
}

StreamBuilder<List<Product>>(
  stream: cartStream,
  builder: (context, snapshot) {
    if (snapshot.hasData) {
      // 购物车有数据，构建显示购物车商品的UI
      List<Product> cartProducts = snapshot.data;
      return ListView.builder(
        itemCount: cartProducts.length,
        itemBuilder: (context, index) {
          return ListTile(
            title: Text(cartProducts[index].name),
            subtitle: Text(cartProducts[index].price.toString()),
          );
        },
      );
    } else if (snapshot.hasError) {
      // 购物车流发生错误，显示错误信息
      return Text('Error: ${snapshot.error}');
    } else {
      // 购物车流还没有数据，显示加载中的UI
      return CircularProgressIndicator();
    }
  },
)