Method watch_restarts

tests/conftest.py:256–268

(self)

            await sleep(0.2)

    async def watch_restarts(self) -> None:  class="cm"># pragma: no cover
        while True:
            if self.should_exit:
                return

            try:
                await asyncio.wait_for(self.restart_requested.wait(), timeout=0.1)
            except asyncio.TimeoutError:
                continue

            self.restart_requested.clear()
            await self.shutdown()
            await self.startup()


def serve_in_thread(server: TestServer) -> typing.Iterator[TestServer]: