如何组合 2 个 Riverpod StreamProvider，其中 1 个流依赖于另一个流的数据？

Question

有时我认为我已经理解了提供者的逻辑，然后我在尝试做下面的事情时被难住了几个小时。

我需要从 firestore collectionsstream 获取连接 ID 列表。简单的。

但是，我需要将这个连接 ID 的流列表提供到另一个 Firestore 集合流中。下面，您可以看到我即将推出的EventsStreamProvider 是 ref.watch 数据库和connectionsStream。Riverpod 或 firestore 没有抛出任何错误。但是，在日志中，我按以下顺序看到打印语句：

returned data
returned null stream value

我如何滥用 Riverpod 提供商的权力？哈哈。

final connectionsStreamProvider = StreamProvider<List<UidConnections>>((ref) {
  final database = ref.watch(databaseProvider);
  return database != null ? database.connectionsStream() : Stream.value(null);
});

final connectionsListStateProvider = StateProvider<List>((ref) => []);

final upcomingEventsStreamProvider = StreamProvider<List<SpecialEvents>>((ref) {
  final database = ref.watch(databaseProvider);
  final connectionsStream = ref.watch(connectionsStreamProvider);
  if (database != null && connectionsStream != null) {
    connectionsStream.whenData((data) {
      if (data != null) {
        data.forEach((event) {
          if (event?.active == true && event?.connectedUid != null) {
            ref
                .read(connectionsListStateProvider)
                .state
                .add(event.connectedUid);
          }
        });
        print('returned data');
        return database.upcomingSpecialEventsStream(
            ref.read(connectionsListStateProvider).state);
      }
    });
  }

  print('returned null stream value');
  return Stream.value(null);
});

或者，我是否只需要重构我的 Firebase Cloud Firestore 查询以首先获取连接 ID 流？我宁愿使用 Riverpod，因为我仍然需要一个单独的连接 ID 流。

Answer 1

仍然对如何单独使用 Riverpod 来完成合并 2 个流感到困惑。但是，我确实设法解决了我的问题，这里为遇到此用例的其他人提供了信息，其中一个流依赖于另一个流的数据。

有效的解决方案（我可能会补充说）是使用rxdart Rx.combineLatest2。见下文。现在 Riverpod 很高兴，并为我的组合流提供状态。感谢 rxdart，我需要的连接 ID 现在是我的帐户模型的一部分。希望这对那里的人有帮助。

final accountInfoStreamProvider = StreamProvider<Account>((ref) {
  final database = ref.watch(databaseProvider);
  return database != null
      ? AccountInfoModel(database: database).accountInfoStream()
      : Stream.value(null);
});

class AccountInfoModel {
  AccountInfoModel({@required this.database});
  final FirestoreDatabase database;

  Stream<Account> accountInfoStream() {
    return Rx.combineLatest2(
      database.accountStream(),
      database.connectionsStream(),
      (Account account, List<Connections> connections) {
        connections.forEach((connection) {
          account.connections.add(connection.documentId);
        });
        return account;
      },
    );
  }
}