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

Question

有时我觉得我已经了解了提供者的逻辑，然后我会被困上几个小时，试图做下面这样的事情。

我需要从消防商店的集合流中获得连接id的列表。容易的

然而，我需要将这个连接id的流媒体列表馈送到另一个firestore集合流中。下面，您可以看到我即将推出的EventsStreamProvider是ref.查看数据库和connectionsStream。riverpod或firestore没有抛出错误。然而，在日志中，我看到我的打印语句的顺序是：

returned data
returned null stream value

我是如何滥用Riverpod提供商的权力的？Lol.

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个流感到困惑。然而，我确实解决了我的问题，下面是其他任何遇到这种流依赖于另一个流的数据的用例的人的信息。

有效的解决方案是使用rxdartRx.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;
},
);
}
}