@@ -91,7 +91,7 @@ export class BucketChecksumState {
91
91
}
92
92
93
93
let checksumMap : util . ChecksumMap ;
94
- if ( updatedBuckets != null ) {
94
+ if ( updatedBuckets != INVALIDATE_ALL_BUCKETS ) {
95
95
if ( this . lastChecksums == null ) {
96
96
throw new ServiceAssertionError ( `Bucket diff received without existing checksums` ) ;
97
97
}
@@ -251,6 +251,8 @@ export class BucketChecksumState {
251
251
}
252
252
}
253
253
254
+ const INVALIDATE_ALL_BUCKETS = Symbol ( 'INVALIDATE_ALL_BUCKETS' ) ;
255
+
254
256
export interface CheckpointUpdate {
255
257
/**
256
258
* All buckets forming part of the checkpoint.
@@ -262,7 +264,7 @@ export interface CheckpointUpdate {
262
264
*
263
265
* If null, assume that any bucket in `buckets` may have been updated.
264
266
*/
265
- updatedBuckets : Set < string > | null ;
267
+ updatedBuckets : Set < string > | typeof INVALIDATE_ALL_BUCKETS ;
266
268
}
267
269
268
270
export class BucketParameterState {
@@ -330,7 +332,7 @@ export class BucketParameterState {
330
332
if ( update . invalidateDataBuckets ) {
331
333
return {
332
334
buckets : querier . staticBuckets ,
333
- updatedBuckets : null
335
+ updatedBuckets : INVALIDATE_ALL_BUCKETS
334
336
} ;
335
337
}
336
338
@@ -397,7 +399,7 @@ export class BucketParameterState {
397
399
return {
398
400
buckets : allBuckets ,
399
401
// We cannot track individual bucket updates for dynamic lookups yet
400
- updatedBuckets : null
402
+ updatedBuckets : INVALIDATE_ALL_BUCKETS
401
403
} ;
402
404
} else {
403
405
return {
0 commit comments