async def METHOD_NAME(self, timeout=None):
    wait_coro = self._closed.wait()
    try:
        await asyncio.wait_for(wait_coro, timeout=timeout)
    except (futures.TimeoutError, asyncio.TimeoutError):
        pass