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

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:188

↓ 6 callersMethodremove_reader

(self, fd: FileDescriptorLike)

src/anyio/_core/_asyncio_selector_thread.py:102

↓ 6 callersMethodsend

(self, item: UDPPacketType)

src/anyio/_backends/_trio.py:624

↓ 6 callersMethodstat

(self, *, follow_symlinks: bool = True)

src/anyio/_core/_fileio.py:871

↓ 6 callersMethodsymlink_to

( self, target: str | bytes | PathLike[str] | PathLike[bytes], target_is_directory: bo

src/anyio/_core/_fileio.py:877

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

↓ 5 callersMethodcancel_shielded_checkpoint

(cls)

src/anyio/_backends/_asyncio.py:2519

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

↓ 5 callersFunctioncycle

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

src/anyio/itertools.py:281

↓ 5 callersMethodfrom_iterable

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

src/anyio/itertools.py:204

↓ 5 callersMethodget_loop

(self)

src/anyio/_backends/_asyncio.py:2290

↓ 5 callersMethodhas_pending_cancellation

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

src/anyio/_core/_testing.py:48

↓ 5 callersMethodis_dir

(self)

src/anyio/_core/_fileio.py:656

↓ 5 callersMethodis_set

(self)

src/anyio/_backends/_trio.py:712

↓ 5 callersFunctionislice

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

src/anyio/itertools.py:374

↓ 5 callersFunctionproduct

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

src/anyio/itertools.py:503

↓ 5 callersMethodrelease

(self)

src/anyio/_backends/_trio.py:832

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

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

src/anyio/_core/_synchronization.py:196

↓ 4 callersMethod__init__

(self)

src/anyio/_core/_exceptions.py:120

↓ 4 callersMethod__init__

(self, *, fast_acquire: bool = False)

src/anyio/_backends/_asyncio.py:1878

↓ 4 callersMethod__new__

(cls, *, fast_acquire: bool = False)

src/anyio/_core/_synchronization.py:158

↓ 4 callersMethod__new__

(cls, *, fast_acquire: bool = False)

src/anyio/_backends/_asyncio.py:1875

↓ 4 callersMethod__new__

(cls, *, fast_acquire: bool = False)

src/anyio/_backends/_trio.py:729

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

↓ 4 callersMethod_wait_until_writable

(self, loop: asyncio.AbstractEventLoop)

src/anyio/_backends/_asyncio.py:1426

↓ 4 callersMethodaclose

(self)

src/anyio/_core/_fileio.py:116

↓ 4 callersMethodaclose

(self)

src/anyio/streams/stapled.py:140

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

↓ 4 callersMethodacquire_nowait

(self)

src/anyio/_backends/_trio.py:818

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

↓ 4 callersMethodexception

The exception raised by the task, or ``None`` if it finished without raising. :raises TaskNotFinished: if the task has not finished

src/anyio/_core/_tasks.py:338

↓ 4 callersFunctionget_callable_name

(func: Callable, override: object = None)

src/anyio/abc/_tasks.py:28

↓ 4 callersMethodget_current_task

(cls)

src/anyio/abc/_eventloop.py:394

↓ 4 callersMethodis_set

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

src/anyio/_core/_synchronization.py:95

↓ 4 callersMethodkill

(self)

src/anyio/_backends/_trio.py:390

↓ 4 callersMethodlocked

Return True if the lock is set.

src/anyio/_core/_synchronization.py:312

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

↓ 4 callersMethodseek

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

src/anyio/_core/_fileio.py:162

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

↓ 4 callersMethodstatistics

(self)

src/anyio/_backends/_trio.py:835

↓ 4 callersFunctiontakewhile

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

src/anyio/itertools.py:570

↓ 4 callersMethodwait

Wait for a notification.

src/anyio/_core/_synchronization.py:335

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

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

↓ 4 callersMethodwrite_bytes

(self, data: ReadableBuffer)

src/anyio/_core/_fileio.py:938

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

↓ 3 callersMethod_call_in_runner_task

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

src/anyio/_backends/_trio.py:1004

↓ 3 callersMethod_check_acquired

(self)

src/anyio/_core/_synchronization.py:289

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

↓ 3 callersMethodaclose

(self)

src/anyio/streams/tls.py:240

↓ 3 callersMethodaclose

(self)

src/anyio/_backends/_trio.py:367

↓ 3 callersMethodacquire

Acquire the underlying lock.

src/anyio/_core/_synchronization.py:293

↓ 3 callersMethodacquire

(self)

src/anyio/_backends/_trio.py:806

↓ 3 callersMethodadd_reader

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

src/anyio/_core/_asyncio_selector_thread.py:68

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

↓ 3 callersMethodcheck_cancelled

(cls)

src/anyio/abc/_eventloop.py:206

↓ 3 callersFunctioncompress

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

src/anyio/itertools.py:248

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

↓ 3 callersMethodcreate_cancel_scope

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

src/anyio/_backends/_trio.py:1118

↓ 3 callersMethodcurrent_time

(cls)

src/anyio/_backends/_asyncio.py:2488

↓ 3 callersFunctiondropwhile

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

src/anyio/itertools.py:299

↓ 3 callersFunctionfilterfalse

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

src/anyio/itertools.py:318

↓ 3 callersFunctionfree_tcp_port_factory

()

src/anyio/pytest_plugin.py:359

↓ 3 callersFunctionget_all_backends

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

src/anyio/_core/_eventloop.py:136

↓ 3 callersFunctionget_runner

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

src/anyio/pytest_plugin.py:46

↓ 3 callersFunctionget_selector

()

src/anyio/_core/_asyncio_selector_thread.py:159

↓ 3 callersMethodglob

(self, pattern: str)

src/anyio/_core/_fileio.py:593

↓ 3 callersFunctiongroupby

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

src/anyio/itertools.py:334

↓ 3 callersMethodis_set

(self)

src/anyio/_backends/_asyncio.py:1859

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

↓ 3 callersMethodrelease

Release the underlying lock.

src/anyio/_core/_synchronization.py:308

↓ 3 callersMethodrglob

(self, pattern: str)

src/anyio/_core/_fileio.py:828

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

(self)

src/anyio/_backends/_trio.py:914

↓ 3 callersFunctiontyped_attribute

Return a unique object, used to mark typed attributes.

src/anyio/_core/_typedattr.py:13

↓ 3 callersMethodunlink

(self, missing_ok: bool = False)

src/anyio/_core/_fileio.py:894

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

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