Skip to content

Commit cd3aa1b

Browse files
snapshot
1 parent b125f75 commit cd3aa1b

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

packages/powersync-sdk-common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -299,10 +299,12 @@ export abstract class AbstractStreamingSyncImplementation extends BaseObserver<S
299299
}
300300

301301
private updateSyncStatus(connected: boolean, lastSyncedAt?: Date) {
302-
const previousValues = [this._isConnected, this._lastSyncedAt?.valueOf()];
302+
const takeSnapShot = () => [this._isConnected, this._lastSyncedAt?.valueOf()];
303+
304+
const previousValues = takeSnapShot();
303305
this._lastSyncedAt = lastSyncedAt ?? this.lastSyncedAt;
304306
this._isConnected = connected;
305-
if (!_.isEqual(previousValues, [this.isConnected, this._lastSyncedAt?.valueOf()])) {
307+
if (!_.isEqual(previousValues, takeSnapShot())) {
306308
this.iterateListeners((cb) => cb.statusChanged?.(new SyncStatus(this.isConnected, this.lastSyncedAt)));
307309
}
308310
}

0 commit comments

Comments
 (0)