Functions — github.com/agronholm/anyio

hub / github.com/agronholm/anyio / functions

Functions2,163 in github.com/agronholm/anyio

⨍ Functions 2,163◇ Types & classes 270↳ Endpoints 11

↓ 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:974

↓ 2 callersMethod__init__

(self, handle_exc: bool = False)

tests/test_contextmanagers.py:24

↓ 2 callersMethod_check

(self)

src/anyio/_core/_tempfile.py:314

↓ 2 callersMethod_check_active

(self, coro: Coroutine | None = None)

src/anyio/_backends/_trio.py:250

↓ 2 callersMethod_check_running

(self)

src/anyio/from_thread.py:212

↓ 2 callersMethod_convert_runtime_error_msg

(exc: RuntimeError)

src/anyio/_backends/_trio.py:737

↓ 2 callersMethod_notify_next_waiter

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

src/anyio/_backends/_asyncio.py:2097

↓ 2 callersMethod_restart_cancellation_in_parent

Restart the cancellation effort in the closest directly cancelled parent scope.

src/anyio/_backends/_asyncio.py:631

↓ 2 callersMethod_run_coro

(self)

src/anyio/_core/_tasks.py:270

↓ 2 callersMethod_run_filestream_test

(self, stream: ByteReceiveStream)

tests/streams/test_file.py:26

↓ 2 callersMethod_spawn

( self, coro: Coroutine[Any, Any, T_co], name: object, task_status_future: asy

src/anyio/_backends/_asyncio.py:830

↓ 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:282

↓ 2 callersMethod_timeout

(self)

src/anyio/_backends/_asyncio.py:573

↓ 2 callersFunction_token_or_error

(token: EventLoopToken | None)

src/anyio/from_thread.py:54

↓ 2 callersMethodaclose

(self)

src/anyio/_core/_tempfile.py:307

↓ 2 callersMethodaclose

(self)

src/anyio/streams/text.py:153

↓ 2 callersMethodaclose

(self)

src/anyio/_backends/_asyncio.py:1129

↓ 2 callersMethodacquire_on_behalf_of_nowait

(self, borrower: object)

src/anyio/_backends/_asyncio.py:2107

↓ 2 callersMethodacquire_on_behalf_of_nowait

(self, borrower: object)

src/anyio/_backends/_trio.py:896

↓ 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:50

↓ 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:312

↓ 2 callersMethodcancel

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

src/anyio/_core/_tasks.py:62

↓ 2 callersMethodcancel

Set the task to a cancelled state. This will interrupt any interruptible asynchronous operation, and will cause any further

src/anyio/_core/_tasks.py:285

↓ 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:100

↓ 2 callersMethodcheckpoint

(cls)

src/anyio/_backends/_trio.py:1102

↓ 2 callersMethodcheckpoint_if_cancelled

(cls)

src/anyio/_backends/_trio.py:1106

↓ 2 callersFunctionclaim_worker_thread

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

src/anyio/_core/_eventloop.py:179

↓ 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:1150

↓ 2 callersMethodcreate_event

(cls)

src/anyio/_backends/_trio.py:1132

↓ 2 callersMethodcreate_lock

(cls, *, fast_acquire: bool)

src/anyio/_backends/_trio.py:1136

↓ 2 callersMethodcreate_semaphore

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

src/anyio/_backends/_trio.py:1140

↓ 2 callersMethodcreate_task

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

src/anyio/_backends/_asyncio.py:913

↓ 2 callersMethodcreate_udp_socket

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

src/anyio/_backends/_trio.py:1285

↓ 2 callersMethodcreate_unix_datagram_socket

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

src/anyio/_backends/_trio.py:1308

↓ 2 callersMethodcurrent_default_thread_limiter

(cls)

src/anyio/abc/_eventloop.py:382

↓ 2 callersMethodcurrent_time

(cls)

src/anyio/_backends/_trio.py:1094

↓ 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:35

↓ 2 callersFunctionfind_root_task

()

src/anyio/_backends/_asyncio.py:311

↓ 2 callersFunctionfree_udp_port_factory

()

src/anyio/pytest_plugin.py:364

↓ 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 callersMethodgroup

(self)

src/anyio/_core/_fileio.py:625

↓ 2 callersFunctionidna2008_resolve

(host: str)

src/anyio/_core/_sockets.py:62

↓ 2 callersFunctionis_anyio_cancellation

(exc: CancelledError)

src/anyio/_backends/_asyncio.py:363

↓ 2 callersMethodis_file

(self)

src/anyio/_core/_fileio.py:666

↓ 2 callersMethodis_symlink

(self)

src/anyio/_core/_fileio.py:693

↓ 2 callersMethodkill

(self)

src/anyio/_backends/_asyncio.py:1164

↓ 2 callersMethodlocked

Return True if the lock is currently held.

src/anyio/_core/_synchronization.py:192

↓ 2 callersMethodlstat

(self)

src/anyio/_core/_fileio.py:715

↓ 2 callersMethodnotify

Notify exactly n listeners.

src/anyio/_core/_synchronization.py:316

↓ 2 callersMethodnotify_all

Notify all the listeners.

src/anyio/_core/_synchronization.py:327

↓ 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:1430

↓ 2 callersMethodread_bytes

(self)

src/anyio/_core/_fileio.py:771

↓ 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:230

↓ 2 callersMethodrelease

(self)

src/anyio/_backends/_asyncio.py:2144

↓ 2 callersMethodrun

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

src/anyio/_backends/_trio.py:1079

↓ 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:95

↓ 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:57

↓ 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:1702

↓ 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:220

↓ 2 callersMethodsleep

(cls, delay: float)

src/anyio/_backends/_trio.py:1114

↓ 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:537

↓ 2 callersMethodstart

( self, func: Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]], *args: Unpack[P

src/anyio/_backends/_asyncio.py:934

↓ 2 callersMethodstatistics

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

src/anyio/_core/_synchronization.py:373

↓ 2 callersMethodstatistics

(self)

src/anyio/_backends/_trio.py:718

↓ 2 callersMethodstop

Signal the portal to shut down. This marks the portal as no longer accepting new calls and exits from :meth:`sleep_until_sto

src/anyio/from_thread.py:224

↓ 2 callersMethodterminate

(self)

src/anyio/_backends/_trio.py:387

↓ 2 callersMethodwait

Wait for the task to finish. This method will return as soon as the task has finished, no matter how it happened.

src/anyio/_core/_tasks.py:395

↓ 2 callersFunctionwait_readable

Wait until the given object has data to be read. On Unix systems, ``obj`` must either be an integer file descriptor, or else an object w

src/anyio/_core/_sockets.py:733

↓ 2 callersMethodwait_readable

(cls, obj: FileDescriptorLike)

src/anyio/_backends/_trio.py:1358

↓ 2 callersFunctionwait_writable

Wait until the given object can be written to. :param obj: an object with a ``.fileno()`` method or an integer handle :raises ~anyio.Clo

src/anyio/_core/_sockets.py:766

↓ 2 callersMethodwait_writable

(cls, obj: FileDescriptorLike)

src/anyio/_backends/_trio.py:1367

↓ 2 callersMethodwith_name

(self, name: str)

src/anyio/_core/_fileio.py:924

↓ 2 callersFunctionzip_longest

( *iterables: Iterable[object] | AsyncIterable[object], fillvalue: object = None, )

src/anyio/itertools.py:590

↓ 1 callersMethod__aenter__

(self)

src/anyio/from_thread.py:199

↓ 1 callersMethod__aenter__

(self)

src/anyio/_core/_tempfile.py:486

↓ 1 callersMethod__aenter__

(self)

src/anyio/_core/_synchronization.py:164

↓ 1 callersMethod__aenter__

(self)

src/anyio/_backends/_trio.py:222

↓ 1 callersMethod__aexit__

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

src/anyio/from_thread.py:203

↓ 1 callersMethod__aexit__

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

src/anyio/_core/_synchronization.py:167

↓ 1 callersMethod__aexit__

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

src/anyio/_backends/_trio.py:232

↓ 1 callersMethod__aexit__

( self, exc_type: object, exc_val: object, exc_tb: object )

tests/test_from_thread.py:344

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