async resume(): Promise<void> {
const cp = await this.store.read(this.group)
- this.offset = cp?.offset ?? 0
+ if (!cp) {
+ throw new MissingCheckpoint(this.group)
+ }
+ this.offset = cp.offset
this.state = 'RUNNING'
}