Method close

reflex/istate/manager/disk.py:376–387

Close the state manager, flushing any pending writes to disk.

(self)

            await self.set_state(token, state, **context)

    async def close(self):
        """Close the state manager, flushing any pending writes to disk."""
        async with self._state_manager_lock:
            if self._write_queue_task:
                self._write_queue_task.cancel()
                with contextlib.suppress(asyncio.CancelledError):
                    await self._write_queue_task
                    self._write_queue_task = None
            # Dump unlocked locks.
            for token, lock in tuple(self._states_locks.items()):
                if not lock.locked():
                    self._states_locks.pop(token)