Skip to content

Commit b8de752

Browse files
committed
Fix usage of insert and disambiguate a type.
1 parent 268bbb8 commit b8de752

File tree

1 file changed

+13
-8
lines changed

1 file changed

+13
-8
lines changed

packages/firestore/src/local/local_documents_view.ts

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -149,16 +149,16 @@ export class LocalDocumentsView {
149149
memoizedOverlays: Map<DocumentKey, Overlay>,
150150
existenceStateChanged: DocumentKeySet
151151
): PersistencePromise<DocumentMap> {
152-
const results = documentMap();
153-
const recalculateDocuments = mutableDocumentMap();
152+
let results = documentMap();
153+
let recalculateDocuments = mutableDocumentMap();
154154
const promises: Array<PersistencePromise<void>> = [];
155155
docs.forEach((_, doc) => {
156156
const overlayPromise = memoizedOverlays.has(doc.key)
157157
? PersistencePromise.resolve(memoizedOverlays.get(doc.key)!)
158158
: this.documentOverlayCache.getOverlay(transaction, doc.key);
159159

160160
promises.push(
161-
overlayPromise.next(overlay => {
161+
overlayPromise.next((overlay: Overlay | null) => {
162162
// Recalculate an overlay if the document's existence state is changed
163163
// due to a remote event *and* the overlay is a PatchMutation. This is
164164
// because document existence state can change if some patch mutation's
@@ -170,7 +170,7 @@ export class LocalDocumentsView {
170170
existenceStateChanged.has(doc.key) &&
171171
(overlay == null || overlay.mutation instanceof PatchMutation)
172172
) {
173-
recalculateDocuments.insert(doc.key, doc);
173+
recalculateDocuments = recalculateDocuments.insert(doc.key, doc);
174174
} else if (overlay !== null) {
175175
mutationApplyToLocalView(
176176
overlay.mutation,
@@ -188,7 +188,9 @@ export class LocalDocumentsView {
188188
this.recalculateAndSaveOverlays(transaction, recalculateDocuments)
189189
)
190190
.next(() => {
191-
docs.forEach((key, value) => results.insert(key, value));
191+
docs.forEach((key, value) => {
192+
results = results.insert(key, value);
193+
});
192194
return results;
193195
});
194196
}
@@ -199,7 +201,7 @@ export class LocalDocumentsView {
199201
): PersistencePromise<void> {
200202
const masks = new Map<DocumentKey, FieldMask | null>();
201203
// A reverse lookup map from batch id to the documents within that batch.
202-
const documentsByBatchId = new SortedMap<number, Set<DocumentKey>>(
204+
let documentsByBatchId = new SortedMap<number, Set<DocumentKey>>(
203205
(key1: number, key2: number) => key1 - key2
204206
);
205207
const processed = new Set<DocumentKey>();
@@ -214,7 +216,10 @@ export class LocalDocumentsView {
214216
mask = batch.applyToLocalViewWithFieldMask(docs.get(key)!, mask);
215217
masks.set(key, mask);
216218
if (documentsByBatchId.get(batch.batchId) === null) {
217-
documentsByBatchId.insert(batch.batchId, new Set<DocumentKey>());
219+
documentsByBatchId = documentsByBatchId.insert(
220+
batch.batchId,
221+
new Set<DocumentKey>()
222+
);
218223
}
219224
documentsByBatchId.get(batch.batchId)!.add(key);
220225
});
@@ -374,7 +379,7 @@ export class LocalDocumentsView {
374379
overlays.forEach(overlay => {
375380
const key = overlay.getKey();
376381
if (remoteDocuments.get(key) === null) {
377-
remoteDocuments.insert(
382+
remoteDocuments = remoteDocuments.insert(
378383
key,
379384
MutableDocument.newInvalidDocument(key)
380385
);

0 commit comments

Comments
 (0)