flutter - 来自 REST API 的实时流数据

Question

我正在使用流从 REST API 检索数据，但是当数据库中的数据更新时，流不会刷新应用中的数据。

StreamController _productsController = new StreamController();
...         
//products is a list that contains the data
_productsController.add(products);
...
body: Container(
        child: StreamBuilder(
            stream: _productsController.stream,
            builder: (BuildContext context, AsyncSnapshot snapshot) {...}

我看到一个解决方案建议定期从 API 重新加载数据，例如每 1 秒一次。

Timer.periodic(Duration(seconds: 1), (_) => loadDetails());

来源：Stream for API coming from PHP in Flutter (Not Firebase)

我不认为这是一种有效的方法。例如，在我的应用中，我想在不重新加载数据的情况下集成数据更改。

有没有一种有效的方法可以让流在不重新加载数据的情况下反映应用中的数据变化？

Answer 1

您可以使用 dart 实现自己的流，如 docs 所示

这样，您还需要延迟，并且您将定期调用 API，但我想如果您的 API 在没有先调用它的情况下不发送任何消息，那么这就是要走的路。

Stream<Product> productsStream() async* {
  while (true) {
    await Future.delayed(Duration(milliseconds: 500));
    Product someProduct = getProductFromAPI();
    yield someProduct;
  }
}

对代码的一点解释：

• 您需要一个循环来定期调用 API。不用担心无限循环，因为只有在构建调用它的 StreamBuild 时才会使用流。
• yield 关键字在使用流时类似于 return

然后，要使用它，只需实现一个 StreamBuilder 调用您刚刚创建的 Stream：

StreamBuilder(
    stream: productsStream(),
    builder: (BuildContext context, AsyncSnapshot<Product> snapshot) {...}
)