Functions — github.com/agronholm/anyio

hub / github.com/agronholm/anyio / functions

Functions2,271 in github.com/agronholm/anyio

⨍ Functions 2,271◇ Types & classes 279↳ Endpoints 10

↓ 3 callersFunctiongroupby

( iterable: Iterable[T] | AsyncIterable[T], )

src/anyio/itertools.py:337

↓ 3 callersMethodis_set

(self)

src/anyio/_backends/_asyncio.py:1929

↓ 3 callersFunctionlru_cache

( *, maxsize: int | None = ..., typed: bool = ..., always_checkpoint: bool = ..., ttl: int

src/anyio/functools.py:277

↓ 3 callersFunctionopen_signal_receiver

Start receiving operating system signals. :param signals: signals to receive (e.g. ``signal.SIGINT``) :return: an asynchronous context m

src/anyio/_core/_signals.py:10

↓ 3 callersFunctionpairwise

( iterable: Iterable[T] | AsyncIterable[T], )

src/anyio/itertools.py:469

↓ 3 callersMethodrelease

Release the underlying lock.

src/anyio/_core/_synchronization.py:314

↓ 3 callersMethodrglob

(self, pattern: str)

src/anyio/_core/_fileio.py:901

↓ 3 callersFunctionset_current_async_library

(asynclib_name: str | None)

src/anyio/_core/_eventloop.py:230

↓ 3 callersFunctionsetup_unix_local_socket

Create a UNIX local socket object, deleting the socket at the given path if it exists. Not available on Windows. :param path: path

src/anyio/_core/_sockets.py:856

↓ 3 callersFunctiontyped_attribute

Return a unique object, used to mark typed attributes.

src/anyio/_core/_typedattr.py:17

↓ 3 callersMethodwait

Wait until the flag has been set. If the flag has already been set when this method is called, it returns immediately.

src/anyio/_core/_synchronization.py:105

↓ 2 callersMethod__aiter__

(self)

src/anyio/_core/_fileio.py:108

↓ 2 callersMethod__enter__

(self)

src/anyio/_backends/_asyncio.py:146

↓ 2 callersMethod__exit__

( self, exc_type: type[BaseException] | None, exc_val: BaseException | None, e

src/anyio/lowlevel.py:124

↓ 2 callersMethod__exit__

( self, exc_type: type[BaseException] | None, exc_val: BaseException | Non

src/anyio/_backends/_asyncio.py:150

↓ 2 callersMethod__exit__

( self, exc_type: type[BaseException] | None, exc_val: BaseException | None, e

src/anyio/_backends/_trio.py:979

↓ 2 callersMethod__init__

(self, handle_exc: bool = False)

tests/test_contextmanagers.py:24

↓ 2 callersMethod_check

(self)

src/anyio/_core/_tempfile.py:315

↓ 2 callersMethod_check_active

(self, coro: Coroutine | None = None)

src/anyio/_backends/_trio.py:254

↓ 2 callersMethod_check_pending

Shortcut for checking if a Future is pending :raises FutureAlreadyFinished: if future was already given a result or exception. :raise

src/anyio/_core/_futures.py:62

↓ 2 callersMethod_check_running

(self)

src/anyio/from_thread.py:214

↓ 2 callersMethod_convert_runtime_error_msg

(exc: RuntimeError)

src/anyio/_backends/_trio.py:742

↓ 2 callersFunction_is_auto_mode

(config: pytest.Config, mode: str)

src/anyio/pytest_plugin.py:106

↓ 2 callersMethod_notify_next_waiter

Hand a free token to the next task in line, if any.

src/anyio/_backends/_asyncio.py:2166

↓ 2 callersMethod_run_coro

(self)

src/anyio/_core/_tasks.py:322

↓ 2 callersMethod_run_filestream_test

(self, stream: ByteReceiveStream)

tests/streams/test_file.py:29

↓ 2 callersMethod_spawn

( self, coro: Coroutine[Any, Any, T_co], name: object, task_status: _AsyncioTa

src/anyio/_backends/_asyncio.py:862

↓ 2 callersMethod_spawn_task_from_thread

Spawn a new task using the given callable. :param func: a callable :param args: positional arguments to be passed to the cal

src/anyio/from_thread.py:284

↓ 2 callersMethod_timeout

(self)

src/anyio/_backends/_asyncio.py:573

↓ 2 callersFunction_token_or_error

(token: EventLoopToken | None)

src/anyio/from_thread.py:55

↓ 2 callersMethodaclose

(self)

src/anyio/_core/_tempfile.py:308

↓ 2 callersMethodaclose

(self)

src/anyio/streams/text.py:153

↓ 2 callersMethodaclose

(self)

src/anyio/_backends/_asyncio.py:1199

↓ 2 callersMethodacquire_on_behalf_of_nowait

(self, borrower: object)

src/anyio/_backends/_asyncio.py:2176

↓ 2 callersMethodas_posix

(self)

src/anyio/_core/_fileio.py:470

↓ 2 callersMethodas_uri

(self)

src/anyio/_core/_fileio.py:473

↓ 2 callersFunctionasyncgen_add

(a: int, b: int)

tests/test_from_thread.py:52

↓ 2 callersMethodcache_clear

(self)

src/anyio/functools.py:89

↓ 2 callersMethodcache_parameters

(self)

src/anyio/functools.py:86

↓ 2 callersMethodcall

( self, func: Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]], *args: Unpack[PosArgs

src/anyio/from_thread.py:314

↓ 2 callersMethodcancel

Cancel this scope immediately. :param reason: a message describing the reason for the cancellation

src/anyio/_core/_tasks.py:60

↓ 2 callersMethodcheckpoint

Check if the task has been cancelled, and allow rescheduling of other tasks. This is effectively the same as running :meth:`checkpoi

src/anyio/abc/_eventloop.py:108

↓ 2 callersMethodcheckpoint

(cls)

src/anyio/_backends/_trio.py:1107

↓ 2 callersMethodcheckpoint_if_cancelled

(cls)

src/anyio/_backends/_trio.py:1111

↓ 2 callersFunctionclaim_worker_thread

( backend_class: type[AsyncBackend], token: object )

src/anyio/_core/_eventloop.py:179

↓ 2 callersMethodclone

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

src/anyio/streams/memory.py:265

↓ 2 callersMethodclose

Close the stream. This works the exact same way as :meth:`aclose`, but is provided as a special case for the benefit of sync

src/anyio/streams/memory.py:150

↓ 2 callersMethodclose

Close the stream. This works the exact same way as :meth:`aclose`, but is provided as a special case for the benefit of sync

src/anyio/streams/memory.py:280

↓ 2 callersMethodcreate_capacity_limiter

(cls, total_tokens: float)

src/anyio/_backends/_trio.py:1155

↓ 2 callersMethodcreate_event

(cls)

src/anyio/_backends/_trio.py:1137

↓ 2 callersMethodcreate_lock

(cls, *, fast_acquire: bool)

src/anyio/_backends/_trio.py:1141

↓ 2 callersMethodcreate_semaphore

( cls, initial_value: int, *, max_value: int | None = None, fast_acqui

src/anyio/_backends/_trio.py:1145

↓ 2 callersMethodcreate_task

( self, coro: Coroutine[Any, Any, T_co], *, name: object = None, conte

src/anyio/_backends/_asyncio.py:964

↓ 2 callersMethodcreate_udp_socket

( cls, family: socket.AddressFamily, local_address: IPSockAddrType | None, rem

src/anyio/_backends/_trio.py:1290

↓ 2 callersMethodcreate_unix_datagram_socket

( cls, raw_socket: socket.socket, remote_path: None )

src/anyio/_backends/_trio.py:1313

↓ 2 callersMethodcurrent_default_thread_limiter

(cls)

src/anyio/abc/_eventloop.py:400

↓ 2 callersMethodcurrent_time

(cls)

src/anyio/_backends/_trio.py:1099

↓ 2 callersMethodcwd

(cls, *, limiter: CapacityLimiter | None = None)

src/anyio/_core/_fileio.py:574

↓ 2 callersMethoddestroy

(self)

src/anyio/to_interpreter.py:44

↓ 2 callersFunctionextract_backend_and_options

(backend: object)

src/anyio/pytest_plugin.py:47

↓ 2 callersFunctionfail

()

tests/test_concurrency_utils.py:32

↓ 2 callersFunctionfind_root_task

()

src/anyio/_backends/_asyncio.py:311

↓ 2 callersFunctionfix_package_names

()

src/anyio/_lazyimport.py:70

↓ 2 callersFunctionfree_udp_port_factory

()

src/anyio/pytest_plugin.py:393

↓ 2 callersFunctiongather

( coro1: Coroutine[Any, Any, R], coro2: Coroutine[Any, Any, S], / )

src/anyio/_core/_concurrency_utils.py:28

↓ 2 callersMethodget_loop

Return embedded event loop.

src/anyio/_backends/_asyncio.py:177

↓ 2 callersFunctionget_running_tasks

Return a list of running tasks in the current event loop. :return: a list of task info objects :raises NoEventLoopError: if no supported

src/anyio/_core/_testing.py:68

↓ 2 callersFunctionidna2008_resolve

(host: str)

src/anyio/_core/_sockets.py:62

↓ 2 callersFunctioninstall_lazy_importer

()

src/anyio/_lazyimport.py:18

↓ 2 callersFunctionis_anyio_cancellation

(exc: CancelledError)

src/anyio/_backends/_asyncio.py:365

↓ 2 callersMethodis_symlink

(self)

src/anyio/_core/_fileio.py:737

↓ 2 callersMethodkill

(self)

src/anyio/_backends/_asyncio.py:1234

↓ 2 callersMethodlocked

Return True if the lock is currently held.

src/anyio/_core/_synchronization.py:198

↓ 2 callersMethodlstat

(self)

src/anyio/_core/_fileio.py:759

↓ 2 callersFunctionmove_on_at

Create a cancel scope with a deadline that expires after the given delay. :param deadline: the deadline before exiting the context block, or

src/anyio/_core/_tasks.py:182

↓ 2 callersMethodnotify

Notify exactly n listeners.

src/anyio/_core/_synchronization.py:322

↓ 2 callersMethodnotify_all

Notify all the listeners.

src/anyio/_core/_synchronization.py:333

↓ 2 callersFunctionnotify_closing

Call this before closing a file descriptor (on Unix) or socket (on Windows). This will cause any `wait_readable` or `wait_writable` calls

src/anyio/_core/_sockets.py:788

↓ 2 callersMethodopen_signal_receiver

( cls, *signals: Signals )

src/anyio/_backends/_trio.py:1435

↓ 2 callersMethodowner

(self, *, follow_symlinks: bool = True)

src/anyio/_core/_fileio.py:812

↓ 2 callersMethodread_bytes

(self)

src/anyio/_core/_fileio.py:826

↓ 2 callersMethodreadinto

(self: AsyncFile[bytes], b: WriteableBuffer)

src/anyio/_core/_fileio.py:131

↓ 2 callersMethodreadinto1

(self: AsyncFile[bytes], b: WriteableBuffer)

src/anyio/_core/_fileio.py:134

↓ 2 callersMethodreceive

(self)

src/anyio/streams/text.py:60

↓ 2 callersMethodreceive

(self)

src/anyio/streams/text.py:144

↓ 2 callersMethodreceive_fds

Receive file descriptors along with a message from the peer. :param msglen: length of the message to expect from the peer :p

src/anyio/abc/_sockets.py:232

↓ 2 callersMethodrelease

(self)

src/anyio/_backends/_asyncio.py:2213

↓ 2 callersFunctionreturn_when

(value: int)

tests/test_concurrency_utils.py:20

↓ 2 callersMethodrun

( cls, func: Callable[[Unpack[PosArgsT]], Awaitable[T_Retval]], args: tuple[Unpack[Pos

src/anyio/_backends/_trio.py:1084

↓ 2 callersFunctionrun_sync

Call a function in the event loop thread from a worker thread. :param func: a callable :param args: positional arguments for the callabl

src/anyio/from_thread.py:96

↓ 2 callersMethodrun_test

Run an async test function. :param test_func: the test function :param kwargs: keyword arguments to call the test function w

src/anyio/abc/_testing.py:63

↓ 2 callersMethodsend

(self, item: str)

src/anyio/streams/text.py:99

↓ 2 callersMethodsend

(self, item: str)

src/anyio/streams/text.py:147

↓ 2 callersMethodsend

(self, item: bytes)

src/anyio/streams/tls.py:260

↓ 2 callersMethodsend

(self, item: UDPPacketType)

src/anyio/_backends/_asyncio.py:1772

↓ 2 callersMethodsend_fds

Send file descriptors along with a message to the peer. :param message: a non-empty bytestring :param fds: a collection of f

src/anyio/abc/_sockets.py:222

↓ 2 callersFunctionset_deprecated_aliases

(aliases: dict[str, str])

src/anyio/_lazyimport.py:91

↓ 2 callersMethodsleep

(cls, delay: float)

src/anyio/_backends/_trio.py:1119

↓ 2 callersFunctionsleep_until

Pause the current task until the given time. :param deadline: the absolute time to wake up at (according to the internal monotonic c

src/anyio/_core/_eventloop.py:110

↓ 2 callersFunctionstarmap

( function: Callable[..., Awaitable[R]], iterable: ( Iterable[Iterable[object] | AsyncIterable

src/anyio/itertools.py:540

← previous next →201–300 of 2,271, ranked by callers