Receive the next item. :raises ~anyio.ClosedResourceError: if the receive stream has been explicitly closed :rai

Receive at most ``max_bytes`` bytes from the peer. .. note:: Implementers of this interface should not return an empty :

Increment the semaphore value.

Release the token held by the given borrower. :raises RuntimeError: if the borrower has not borrowed a token from this l

Run an async generator fixture. :param fixture_func: the fixture function :param kwargs: keyword arguments to call the fixtu

Run an async fixture. :param fixture_func: the fixture function :param kwargs: keyword arguments to call the fixture functio

Call the given function with the given arguments in a worker thread. If the ``abandon_on_cancel`` option is enabled and the task waiting for

Sleep until :meth:`stop` is called.

Return statistics about the current state of this stream. .. versionadded:: 3.0

.. deprecated:: 4.7.0 Use :func:`wait_readable` instead. Wait until the given socket has data to be read. .. warning:: Only use

.. deprecated:: 4.7.0 Use :func:`wait_writable` instead. Wait until the given socket can be written to. This does **NOT** work o

Wrap an existing file as an asynchronous file. :param file: an existing file-like object :param limiter: an optional capacity limiter to

Enter the task group context and allow starting new tasks.