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

Return a token object that can be used to call code in the current event loop from another thread. :raises NoEventLoopError: if no suppo

src/anyio/lowlevel.py:83

↓ 6 callersMethodis_set

(self)

src/anyio/_backends/_trio.py:717

↓ 6 callersMethodlocked

(self)

src/anyio/_backends/_trio.py:775

↓ 6 callersFunctionopen_file

( file: str | PathLike[str] | int, mode: OpenBinaryMode, buffering: int = ..., encoding: str |

src/anyio/_core/_fileio.py:175

↓ 6 callersFunctionpermutations

( iterable: Iterable[T] | AsyncIterable[T], r: int | None = None )

src/anyio/itertools.py:490

↓ 6 callersMethodreceive_exactly

Read exactly the given amount of bytes from the stream. :param nbytes: the number of bytes to read :return: the bytes read

src/anyio/streams/buffered.py:91

↓ 6 callersMethodrelease

Release the lock.

src/anyio/_core/_synchronization.py:194

↓ 6 callersMethodremove_reader

(self, fd: FileDescriptorLike)

src/anyio/_core/_asyncio_selector_thread.py:102

↓ 6 callersMethodseek

(self, offset: int, whence: int | None = os.SEEK_SET)

src/anyio/_core/_fileio.py:162

↓ 6 callersMethodsend

(self, item: UDPPacketType)

src/anyio/_backends/_trio.py:629

↓ 6 callersMethodstat

(self, *, follow_symlinks: bool = True)

src/anyio/_core/_fileio.py:944

↓ 6 callersMethodunwrap

Does the TLS closing handshake. :return: a tuple of (wrapped byte stream, bytes left in the read buffer)

src/anyio/streams/tls.py:228

↓ 5 callersFunctionaccumulate

( iterable: Iterable[T] | AsyncIterable[T], function: Callable[[T, T], Awaitable[T]] = _operator_add,

src/anyio/itertools.py:150

↓ 5 callersFunctionas_completed

Run awaitable objects concurrently in a task group, returning an iterator which can be used to get finished task handles in the order they co

src/anyio/_core/_concurrency_utils.py:97

↓ 5 callersMethodcancel_shielded_checkpoint

(cls)

src/anyio/_backends/_asyncio.py:2586

↓ 5 callersMethodcopy

( self, target: str | os.PathLike[str], *, follow_symlinks: bo

src/anyio/_core/_fileio.py:503

↓ 5 callersFunctioncurrent_async_library

()

src/anyio/_core/_eventloop.py:211

↓ 5 callersFunctioncurrent_effective_deadline

Return the nearest deadline among all the cancel scopes effective for the current task. :return: a clock value from the event loop's int

src/anyio/_core/_tasks.py:222

↓ 5 callersFunctioncycle

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

src/anyio/itertools.py:284

↓ 5 callersMethodfrom_iterable

( self, iterables: ( Iterable[Iterable[T] | AsyncIterable[T]] | AsyncI

src/anyio/itertools.py:207

↓ 5 callersMethodget_loop

(self)

src/anyio/_backends/_asyncio.py:2357

↓ 5 callersMethodhas_pending_cancellation

Return ``True`` if the task has a cancellation pending, ``False`` otherwise.

src/anyio/_core/_testing.py:48

↓ 5 callersMethodis_set

Return ``True`` if the flag is set, ``False`` if not.

src/anyio/_core/_synchronization.py:101

↓ 5 callersFunctionislice

( iterable: Iterable[T] | AsyncIterable[T], stop: int | None, /, )

src/anyio/itertools.py:377

↓ 5 callersFunctionproduct

( *iterables: Iterable[T] | AsyncIterable[T], repeat: int = 1 )

src/anyio/itertools.py:506

↓ 5 callersMethodrelease

(self)

src/anyio/_backends/_trio.py:837

↓ 5 callersMethodremove_writer

(self, fd: FileDescriptorLike)

src/anyio/_core/_asyncio_selector_thread.py:116

↓ 5 callersMethodreset

Restore this run variable to the value it held before the matching :meth:`set`. :param token: the token returned by :meth:`set`

src/anyio/lowlevel.py:202

↓ 5 callersMethodsend_eof

(self)

src/anyio/streams/tls.py:263

↓ 5 callersFunctionsleep_forever

Pause the current task until it's cancelled. This is a shortcut for ``sleep(math.inf)``. .. versionadded:: 3.1

src/anyio/_core/_eventloop.py:98

↓ 5 callersMethodstatistics

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

src/anyio/_core/_synchronization.py:202

↓ 5 callersMethodwrite_bytes

(self, data: ReadableBuffer)

src/anyio/_core/_fileio.py:1023

↓ 4 callersMethod__init__

(self)

src/anyio/_core/_exceptions.py:120

↓ 4 callersMethod__init__

(self, *, fast_acquire: bool = False)

src/anyio/_backends/_asyncio.py:1948

↓ 4 callersMethod__new__

(cls, *, fast_acquire: bool = False)

src/anyio/_core/_synchronization.py:164

↓ 4 callersMethod__new__

(cls, *, fast_acquire: bool = False)

src/anyio/_backends/_asyncio.py:1945

↓ 4 callersMethod__new__

(cls, *, fast_acquire: bool = False)

src/anyio/_backends/_trio.py:734

↓ 4 callersMethod_call_sslobject_method

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

src/anyio/streams/tls.py:182

↓ 4 callersMethod_wait_until_readable

(self, loop: asyncio.AbstractEventLoop)

src/anyio/_backends/_asyncio.py:1486

↓ 4 callersMethod_wait_until_writable

(self, loop: asyncio.AbstractEventLoop)

src/anyio/_backends/_asyncio.py:1496

↓ 4 callersMethodaclose

(self)

src/anyio/_core/_fileio.py:116

↓ 4 callersMethodaclose

(self)

src/anyio/streams/stapled.py:150

↓ 4 callersFunctionaclose_forcefully

Close an asynchronous resource in a cancelled scope. Doing this closes the resource without waiting on anything. :param resource: the r

src/anyio/_core/_resources.py:7

↓ 4 callersMethodacquire

()

tests/test_synchronization.py:176

↓ 4 callersMethodacquire_nowait

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

src/anyio/_core/_synchronization.py:185

↓ 4 callersMethodacquire_nowait

(self)

src/anyio/_backends/_trio.py:823

↓ 4 callersMethodadd_writer

(self, fd: FileDescriptorLike, callback: Callable[[], Any])

src/anyio/_core/_asyncio_selector_thread.py:85

↓ 4 callersFunctionassert_checkpoints_on_first_next

(iterator: AsyncIterator[Any])

tests/test_itertools.py:80

↓ 4 callersMethodcheckpoint_if_cancelled

(cls)

src/anyio/_backends/_asyncio.py:2567

↓ 4 callersMethodcreate_cancel_scope

( cls, *, deadline: float = math.inf, shield: bool = False )

src/anyio/_backends/_trio.py:1123

↓ 4 callersMethodexception

The exception value of a `.Future` :raises FutureNotFinished: if future is still pending :raises FutureCancelled: if future

src/anyio/_core/_futures.py:96

↓ 4 callersFunctionfail_at

Create a context manager which raises a :class:`TimeoutError` if the code in the enclosing context does not finish by the given deadline.

src/anyio/_core/_tasks.py:128

↓ 4 callersFunctionget_callable_name

(func: Callable, override: object = None)

src/anyio/abc/_tasks.py:42

↓ 4 callersMethodget_current_task

(cls)

src/anyio/abc/_eventloop.py:412

↓ 4 callersMethodis_file

(self, *, follow_symlinks: bool = True)

src/anyio/_core/_fileio.py:701

↓ 4 callersMethodkill

(self)

src/anyio/_backends/_trio.py:395

↓ 4 callersMethodlocked

Return True if the lock is set.

src/anyio/_core/_synchronization.py:318

↓ 4 callersMethodreceive

(self, max_bytes: int = 65536)

src/anyio/streams/buffered.py:67

↓ 4 callersMethodreceive_until

Read from the stream until the delimiter is found or max_bytes have been read. :param delimiter: the marker to look for in the strea

src/anyio/streams/buffered.py:118

↓ 4 callersFunctionrepeat

(element: T, times: int | None = None)

src/anyio/itertools.py:522

↓ 4 callersMethodsend_nowait

(self, item: T_Item)

src/anyio/streams/stapled.py:88

↓ 4 callersMethodstatistics

(self)

src/anyio/_backends/_trio.py:840

↓ 4 callersMethodstatistics

(self)

src/anyio/_backends/_trio.py:919

↓ 4 callersFunctiontakewhile

( predicate: Callable[[T], Awaitable[object]], iterable: Iterable[T] | AsyncIterable[T], )

src/anyio/itertools.py:573

↓ 4 callersMethodunlink

(self, missing_ok: bool = False)

src/anyio/_core/_fileio.py:967

↓ 4 callersMethodwait

Wait for a notification.

src/anyio/_core/_synchronization.py:341

↓ 4 callersMethodwait_for

Wait until a predicate becomes true. :param predicate: a callable that returns a truthy value when the condition is met

src/anyio/_core/_synchronization.py:363

↓ 4 callersMethodwrap_async_context_manager

Wrap an async context manager as a synchronous context manager via this portal. Spawns a task that will call both ``__aenter__()`` a

src/anyio/from_thread.py:430

↓ 3 callersMethod__anext__

(self)

tests/test_itertools.py:57

↓ 3 callersMethod_call_in_runner_task

( self, func: Callable[P, Awaitable[T_Retval]], /, *args: P.args, **kw

src/anyio/_backends/_asyncio.py:2413

↓ 3 callersMethod_call_in_runner_task

( self, func: Callable[P, Awaitable[T_Retval]], /, *args: P.args, **kw

src/anyio/_backends/_trio.py:1009

↓ 3 callersMethod_check_acquired

(self)

src/anyio/_core/_synchronization.py:295

↓ 3 callersMethod_deliver_cancellation

Deliver cancellation to directly contained tasks and nested cancel scopes. Schedule another run at the end if we still have tasks el

src/anyio/_backends/_asyncio.py:581

↓ 3 callersMethod_do_cache_asserts

( wrapper: _LRUMethodWrapper[int] | AsyncLRUCacheWrapper[..., int], )

tests/test_functools.py:286

↓ 3 callersMethod_lazy_init

(self)

src/anyio/_backends/_asyncio.py:230

↓ 3 callersMethod_notify_self

(self)

src/anyio/_core/_asyncio_selector_thread.py:62

↓ 3 callersMethod_raise_async_exceptions

(self)

src/anyio/_backends/_asyncio.py:2375

↓ 3 callersMethod_restart_cancellation_in_parent

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

src/anyio/_backends/_asyncio.py:631

↓ 3 callersMethodaclose

(self)

src/anyio/streams/tls.py:240

↓ 3 callersMethodaclose

(self)

src/anyio/_backends/_trio.py:372

↓ 3 callersMethodacquire

Acquire the underlying lock.

src/anyio/_core/_synchronization.py:299

↓ 3 callersMethodacquire

(self)

src/anyio/_backends/_trio.py:811

↓ 3 callersMethodacquire_on_behalf_of_nowait

(self, borrower: object)

src/anyio/_backends/_trio.py:901

↓ 3 callersMethodadd_reader

(self, fd: FileDescriptorLike, callback: Callable[[], Any])

src/anyio/_core/_asyncio_selector_thread.py:68

↓ 3 callersFunctionamap

Run the given coroutine function concurrently for multiple argument values. :param func: a coroutine function that takes a single argument

src/anyio/_core/_concurrency_utils.py:141

↓ 3 callersFunctioncall_for_coroutine

Call the given function with the given positional and keyword arguments. :return: the resulting coroutine :raises TypeError: if the retu

src/anyio/abc/_tasks.py:51

↓ 3 callersMethodcheck_cancelled

(cls)

src/anyio/abc/_eventloop.py:214

↓ 3 callersFunctioncompress

( data: Iterable[T] | AsyncIterable[T], selectors: Iterable[object] | AsyncIterable[object], )

src/anyio/itertools.py:251

↓ 3 callersFunctionconvert_ipv6_sockaddr

Convert a 4-tuple IPv6 socket address to a 2-tuple (address, port) format. If the scope ID is nonzero, it is added to the address, separated

src/anyio/_core/_sockets.py:825

↓ 3 callersFunctioncount

(start: int = 0, step: int = 1)

src/anyio/itertools.py:274

↓ 3 callersMethodcurrent_time

(cls)

src/anyio/_backends/_asyncio.py:2555

↓ 3 callersFunctiondropwhile

( predicate: Callable[[T], Awaitable[object]], iterable: Iterable[T] | AsyncIterable[T], )

src/anyio/itertools.py:302

↓ 3 callersFunctionfilterfalse

( predicate: Callable[[T], Awaitable[object]], iterable: Iterable[T] | AsyncIterable[T], )

src/anyio/itertools.py:321

↓ 3 callersFunctionfree_tcp_port_factory

()

src/anyio/pytest_plugin.py:388

↓ 3 callersFunctionget_all_backends

Return a tuple of the names of all built-in backends.

src/anyio/_core/_eventloop.py:136

↓ 3 callersFunctionget_coro_name

(coro: Coroutine[Any, Any, object], override: object = None)

src/anyio/abc/_tasks.py:28

↓ 3 callersFunctionget_runner

( backend_name: str, backend_options: dict[str, Any] )

src/anyio/pytest_plugin.py:58

↓ 3 callersFunctionget_selector

()

src/anyio/_core/_asyncio_selector_thread.py:159

↓ 3 callersMethodglob

(self, pattern: str)

src/anyio/_core/_fileio.py:604

↓ 3 callersMethodgroup

(self, *, follow_symlinks: bool = True)

src/anyio/_core/_fileio.py:638

← previous next →101–200 of 2,271, ranked by callers