Stream无法识别数据库中的更改。

问题出现的原因是Stream已经在创建后从数据库获取数据，但在此后数据库中的数据发生了更改，Stream并没有意识到这一点。为了解决这个问题，您需要使用一个Observable并确保它可以及时地检测到数据库中的任何更改。以下是一个代码示例：

class Database {
  Observable<List<Data>> onDataChanged = Observable<List<Data>>();

  void updateData(List<Data> newData) {
    // 更新数据库中存储的数据
    onDataChanged.notifyListeners(newData); // 通知观察者数据已更改
  }
}

class StreamClass {
  Stream<List<Data>> dataStream;

  StreamClass(Database database) {
    // 使用Observable来监听数据更改
    dataStream = database.onDataChanged
        .startWith(database.getData())
        .asBroadcastStream();
  }
}

在上面的示例中，Database类有一个名为onDataChanged的Observable。这个Observable在数据发生更改时通知订阅它的观察者。而StreamClass类使用Observable来监听数据更改并更新其数据流。通过这种方式，StreamClass类可以实时地获取到数据库的变化。