Function pullOnce

packages/rpc/src/sync-driver.ts:69–78

(
  db: Database,
  remote: SyncRPC,
  backend?: string,
)

// cursor is read and written per backend so concurrent backends keep
// independent resume points.
export async function pullOnce(
  db: Database,
  remote: SyncRPC,
  backend?: string,
): Promise<ApplyResult> {
  // Delegate to the inner implementation with retried=false. See
  // pullOnceImpl for the fetchChanges round trip, invariant check,
  // reset-and-retry path, and batched apply loop.
  return pullOnceImpl(db, remote, backend, false);
}

// Inner pullOnce that knows whether it is already a retry. The
// outer pullOnce always enters with retried=false; on a watermark