来自 onSnapshot 的 Firebase 9 数组
Firebase 9 array from onSnapshot
所以我需要将数据从 Firebase 9 快照转换为数组。
我想到了类似的东西,但 return 什么都没有。
检查我代码中的注释。
我想,我应该使用 promises,但找不到正确的方法。
const fetchNewMessages = async (threadId: string, latestTimestamp: any) => {
const q = query(threadRef(threadId), orderBy('timestamp', 'asc'), startAfter(latestTimestamp));
const messages: IMessage[] = [];
onSnapshot(q, (querySnapshot) => {
const docs = querySnapshot.docChanges();
docs.forEach((change) => {
if (change.type === "added")
messages.push(fetchDoc(change.doc));
});
console.log(messages.length); // here I get 34
});
console.log(messages.length); // here I get 0
return messages.reverse();
};
尝试等待“onSnapshot”
const fetchNewMessages = (threadId: string, latestTimestamp: any) => {
const q = query(threadRef(threadId), orderBy('timestamp', 'asc'), startAfter(latestTimestamp));
const messages: IMessage[] = [];
return new Promise((resolve) => {
onSnapshot(q, (querySnapshot) => {
const docs = querySnapshot.docChanges();
docs.forEach((change) => {
if (change.type === "added")
messages.push(fetchDoc(change.doc));
});
resolve(messages.reverse());
});
});
};
所以我需要将数据从 Firebase 9 快照转换为数组。
我想到了类似的东西,但 return 什么都没有。
检查我代码中的注释。
我想,我应该使用 promises,但找不到正确的方法。
const fetchNewMessages = async (threadId: string, latestTimestamp: any) => {
const q = query(threadRef(threadId), orderBy('timestamp', 'asc'), startAfter(latestTimestamp));
const messages: IMessage[] = [];
onSnapshot(q, (querySnapshot) => {
const docs = querySnapshot.docChanges();
docs.forEach((change) => {
if (change.type === "added")
messages.push(fetchDoc(change.doc));
});
console.log(messages.length); // here I get 34
});
console.log(messages.length); // here I get 0
return messages.reverse();
};
尝试等待“onSnapshot”
const fetchNewMessages = (threadId: string, latestTimestamp: any) => {
const q = query(threadRef(threadId), orderBy('timestamp', 'asc'), startAfter(latestTimestamp));
const messages: IMessage[] = [];
return new Promise((resolve) => {
onSnapshot(q, (querySnapshot) => {
const docs = querySnapshot.docChanges();
docs.forEach((change) => {
if (change.type === "added")
messages.push(fetchDoc(change.doc));
});
resolve(messages.reverse());
});
});
};