Flutterの別のストリームの入力としてFirebaseストリームを使用していますか？
コンテキスト：正しく機能する2つのFirebaseストリームがあり、i）ユーザープロファイルのリスト（「users」コレクション）、ii）各ユーザープロファイルに属する場所のリスト（「locations」コレクション）、および次に、それらをカスタムのユーザーと場所のモデルにマッピングします。
ユーザーストリーム：
class DatabaseService {
final String uid;
final String friendUid;
final String locationId;
DatabaseService({ this.uid, this.locationId, this.friendUid });
// collection reference for users
final CollectionReference userCollection = FirebaseFirestore.instance.collection('users');
// get users stream
Stream<List<CustomUserModel>> get users {
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
List<CustomUserModel> userList = [];
List<CustomUserModel> _streamMapper(DocumentSnapshot snapshot) {
CustomUserModel individualUser = CustomUserModel(
uid: snapshot.id,
name: snapshot.data()['name'],
username: snapshot.data()['username'],
email: snapshot.data()['email'],
);
userList.add(individualUser);
return userList;
}
return userCollection.doc(uid).snapshots().map(_streamMapper);
}
およびロケーションストリーム：
// collection reference for location
final CollectionReference locationCollection =
FirebaseFirestore.instance.collection('locations');
Stream<List<Location>> get locations {
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
List<Location> _locationListFromSnapshot(QuerySnapshot snapshot) {
List<Location> locationList = [];
snapshot.docs.forEach((element) {
Location individualLocation = Location(
locationId: element.id,
locationName: element.data()['locationName'],
city: element.data()['city'],
);
locationList.add(individualLocation);
});
return locationList;
}
return userLocationCollection.doc(uid).collection('locations').snapshots()
.map(_locationListFromSnapshot);
}
私がやりたいのは、すべてのユーザーのすべての場所を出力するカスタムストリームを生成することです。つまり、ユーザーストリームを場所ストリームの入力として使用します。
ここでどのアプローチが機能するかわかりません-ユーザーストリームを入力パラメーターとしてロケーションストリームに追加してから、次のようなforループを作成することを検討しました。
Stream<List<Location>> allLocations(Stream<List<CustomUserModel>> users) {
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
List<Location> locationList = [];
users.forEach((element) {
// append user's locations to empty list
locationList.add(locationCollection.doc(element.first.uid).collection('locations')
.snapshots().map(SOME FUNCTION TO MAP A DOCUMENT SNAPSHOT TO THE CUSTOM LOCATION MODEL)
}
return locationList;
しかしもちろん、これはストリームではなくリストを返すため、エラーが発生します。だから私はどのように進めるのか分かりません...
回答
あなたの痛みが聞こえます。私はそこに行ったことがあります。あなたはかなり近かった。私がそれをどのように行うのが好きかを説明させてください。
まず第一に、いくつかのクリーンアップ：
allLocations関数で使用していないようだったので削除しました
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
第二に、私はからの関数の戻り値の型を変更Stream<List<Location>>するStream<Map<String, List<Location>>マップの鍵はuserIdをだろう場所。ストリームと同期しているユーザーの順序を気にする必要がないので、このタイプは便利だと思います。
第三に、ストリームを作成しているときは、戻ることはできませんが、関数から譲る必要があります。また、関数をマークする必要がありますasync*（*はタイプミスではありません）。
これで、私はあなたがあなたのallLocations関数のためにこのようなものを使うことを提案します：
class DataService {
List<Location> convertToLocations(QuerySnapshot snap) {
// This is the function to convert QuerySnapshot into List<Location>
return [Location()];
}
Stream<Map<String, List<Location>>> allLocations(
Stream<List<CustomUserModel>> usersStream) async* {
Map<String, List<Location>> locationsMap = {};
await for (List<CustomUserModel> users in usersStream) {
for (CustomUserModel user in users) {
final Stream<List<Location>> locationsStream = locationCollection
.doc(user.uid)
.collection('locations')
.snapshots()
.map(convertToLocations);
await for (List<Location> locations in locationsStream) {
locationsMap[user.uid] = locations;
yield locationsMap;
}
}
}
}
}
この方法が気に入っていただければ幸いです。何かがあなたが望むものでないならば、私に知らせてください。調整できます。