Skip to content

Commit ffa9bdb

Browse files
committed
Alos set applied checkpoint
1 parent 8343fee commit ffa9bdb

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

packages/common/src/client/sync/stream/AbstractStreamingSyncImplementation.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -687,7 +687,12 @@ The next upload iteration will be delayed.`);
687687

688688
if ('crud_upload_completed' in line) {
689689
if (validatedCheckpoint != null) {
690-
await this.applyCheckpoint(validatedCheckpoint);
690+
const { applied, endIteration } = await this.applyCheckpoint(validatedCheckpoint);
691+
if (applied) {
692+
appliedCheckpoint = validatedCheckpoint;
693+
} else if (endIteration) {
694+
break;
695+
}
691696
}
692697

693698
continue;

0 commit comments

Comments
 (0)