Implement your async context manager logic here. This method **must** be decorated with :func:`@asynccontextmanager <context

Implement your context manager logic here. This method **must** be decorated with :func:`@contextmanager <contextlib.context

Schedule the shutdown of the default executor.

Shuts down worker processes belonging to this event loop. NOTE: this only works when the event loop was started using asyncio.run() or a

Return ``True`` if the task has been started and has not finished.

Close the resource.

Decrement the semaphore value, blocking if necessary.

Acquire the underlying lock, without blocking. :raises ~anyio.WouldBlock: if the operation would block

Acquire a token, waiting if necessary for one to become available. :param borrower: the entity borrowing a token

Acquire a token without waiting for one to become available. :param borrower: the entity borrowing a token :raises ~anyio.Wo

Allow the rescheduling of other tasks. This will give other tasks the opportunity to run, but without checking if the curren

Check if the current task group has been cancelled. This will check if the task has been cancelled, but will not allow other tasks

Create a clone of this send stream. Each clone can be closed separately. Only when all clones have been closed will the send

Return the capacity limiter used by default to limit the number of concurrently running subinterpreters. Defaults to the number of CPU c

Return the capacity limiter that is used by default to limit the number of worker processes. :return: a capacity limiter object

Return the nearest deadline among all the cancel scopes effective for the current task. :return: - a clock value

Return an object that allows other threads to run code inside the event loop. :return: a token object, specific to the event loop ru

Append data directly into the buffer. Any data in the buffer will be consumed by receive operations before receiving anythin

Return embedded event loop.

Look up the host name of an IP address. :param sockaddr: socket address (e.g. (ipaddress, port) for IPv4) :param flags: flags to pass to

Asynchronously return the name of the directory used for temporary files. This function wraps `tempfile.gettempdir` and executes it in a bac

Asynchronously return the name of the directory used for temporary files in bytes. This function wraps `tempfile.gettempdirb` and executes i

Handle an exception raised during the TLS handshake. This method does 3 things: #. Forcefully closes the original stream

Check if the test runner is running. :return: ``True`` if the coroutine is currently being run, ``False`` otherwise.