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

Methodborrowed_tokens

(self)

src/anyio/_core/_synchronization.py:697

Methodborrowed_tokens

(self)

src/anyio/_backends/_asyncio.py:2090

Methodborrowed_tokens

(self)

src/anyio/_backends/_trio.py:883

Methodborrower

( event: Event, *, task_status: TaskStatus[CancelScope] )

tests/test_synchronization.py:955

Methodbuffer

The bytes currently in the buffer.

src/anyio/streams/buffered.py:46

Functionca

()

tests/conftest.py:139

Functioncache

( # type: ignore[overload-overlap] func: Callable[P, Coroutine[Any, Any, T]], / )

src/anyio/functools.py:257

Methodcache_clear

(self)

src/anyio/functools.py:132

Methodcache_info

(self)

src/anyio/functools.py:119

Methodcache_parameters

(self)

src/anyio/functools.py:124

Methodcallback

(f: object)

src/anyio/_backends/_asyncio.py:1417

Methodcancel

(self, reason: str | None = None)

src/anyio/_backends/_trio.py:166

Methodcancel_called

``True`` if :meth:`cancel` has been called.

src/anyio/_core/_tasks.py:86

Methodcancel_called

(self)

src/anyio/_backends/_asyncio.py:682

Methodcancel_called

(self)

src/anyio/_backends/_trio.py:178

Functioncancel_group

()

tests/test_taskgroups.py:571

Methodcancel_shielded_checkpoint

(cls)

src/anyio/_backends/_trio.py:1110

Functioncancel_when_ready

()

tests/test_taskgroups.py:760

Methodcancelled_caught

``True`` if this scope suppressed a cancellation exception it itself raised. This is typically used to check if any work was interru

src/anyio/_core/_tasks.py:91

Methodcancelled_caught

(self)

src/anyio/_backends/_asyncio.py:686

Methodcancelled_caught

(self)

src/anyio/_backends/_trio.py:182

Methodcancelled_exception_class

Return the exception class that is raised in a task if it's cancelled.

src/anyio/abc/_eventloop.py:95

Methodcancelled_exception_class

(cls)

src/anyio/_backends/_asyncio.py:2492

Functioncanceller

()

tests/test_from_thread.py:82

Methodcb

()

src/anyio/_backends/_asyncio.py:2910

Functioncheck_asyncio_bug

(anyio_backend_name: str, family: AnyIPAddressFamily)

tests/test_sockets.py:142

Functioncheck_body_exc

(exc: RuntimeError, /)

tests/test_taskgroups.py:1218

Functioncheck_cancelled

Check if the cancel scope of the host task's running the current worker thread has been cancelled. If the host task's current cancel sco

src/anyio/from_thread.py:563

Methodcheck_cancelled

(cls)

src/anyio/_backends/_asyncio.py:2644

Methodcheck_cancelled

(cls)

src/anyio/_backends/_trio.py:1173

Methodcheck_thread

()

tests/test_to_thread.py:308

Functionchild

()

tests/test_taskgroups.py:500

Methodchild_task

(task_status: TaskStatus[None])

tests/test_taskgroups.py:1655

Functionclient_context

(ca: CA)

tests/conftest.py:154

Methodclone

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

src/anyio/streams/memory.py:135

Methodclose_when_blocked

()

tests/test_sockets.py:1858

Methodclose_when_blocked

()

tests/test_sockets.py:2037

Methodclose_when_blocked

()

tests/test_sockets.py:2197

Methodclose_when_blocked

()

tests/test_sockets.py:2395

Methodclosed

(self)

src/anyio/_core/_tempfile.py:334

Methodconnect

Connect to the remote endpoint. :return: an object stream connected to the remote end :raises ConnectionFailed: if the conne

src/anyio/abc/_streams.py:212

Methodconnect

Connect to the remote endpoint. :return: a bytestream connected to the remote end :raises ConnectionFailed: if the connectio

src/anyio/abc/_streams.py:223

Methodconnect

(self)

tests/streams/test_buffered.py:101

Methodconnect

(self)

tests/streams/test_text.py:88

Methodconnect_sync

(addr: tuple[str, int])

tests/streams/test_tls.py:538

Methodconnect_tcp

( cls, host: str, port: int, local_address: IPSockAddrType | None = None )

src/anyio/abc/_eventloop.py:249

Methodconnect_tcp

( cls, host: str, port: int, local_address: IPSockAddrType | None = None )

src/anyio/_backends/_asyncio.py:2778

Methodconnect_unix

(cls, path: str | bytes)

src/anyio/abc/_eventloop.py:256

Methodconnect_unix

(cls, path: str | bytes)

src/anyio/_backends/_asyncio.py:2791

Methodconnection_lost

(self, exc: Exception | None)

src/anyio/_backends/_asyncio.py:1256

Methodconnection_lost

(self, exc: Exception | None)

src/anyio/_backends/_asyncio.py:1294

Methodconnection_made

(self, transport: asyncio.BaseTransport)

src/anyio/_backends/_asyncio.py:1249

Methodconnection_made

(self, transport: asyncio.BaseTransport)

src/anyio/_backends/_asyncio.py:1287

Functionconsume

(sigiter: AsyncIterable[int])

tests/test_signals.py:54

Methodconvert_item

(item: StrOrBytesPath)

src/anyio/_backends/_trio.py:1212

Methodcoro

The coroutine object that was passed to one of the task-spawning methods in :class:`TaskGroup`.

src/anyio/_core/_tasks.py:299

Methodcoro_fn

()

tests/test_taskgroups.py:1884

Functioncorofunc

()

tests/test_taskgroups.py:1351

Functioncrash

()

tests/test_taskgroups.py:1503

Methodcreate_cancel_scope

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

src/anyio/_backends/_asyncio.py:2528

Methodcreate_capacity_limiter

(cls, total_tokens: float)

src/anyio/abc/_eventloop.py:190

Methodcreate_capacity_limiter

(cls, total_tokens: float)

src/anyio/_backends/_asyncio.py:2579

Functioncreate_custom_task

( coro: Coroutine[Any, Any, Any], /, **kwargs: Any )

tests/test_taskgroups.py:1994

Methodcreate_event

(cls)

src/anyio/abc/_eventloop.py:169

Methodcreate_event

(cls)

src/anyio/_backends/_asyncio.py:2561

Methodcreate_lock

(cls, *, fast_acquire: bool)

src/anyio/abc/_eventloop.py:174

Methodcreate_lock

(cls, *, fast_acquire: bool)

src/anyio/_backends/_asyncio.py:2565

Methodcreate_semaphore

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

src/anyio/abc/_eventloop.py:179

Methodcreate_semaphore

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

src/anyio/_backends/_asyncio.py:2569

Methodcreate_task

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

src/anyio/_backends/_trio.py:259

Methodcreate_task_group

(cls)

src/anyio/_backends/_asyncio.py:2557

Methodcreate_tcp_listener

(cls, sock: socket)

src/anyio/abc/_eventloop.py:261

Methodcreate_tcp_listener

(cls, sock: socket.socket)

src/anyio/_backends/_asyncio.py:2811

Methodcreate_test_runner

(cls, options: dict[str, Any])

src/anyio/_backends/_asyncio.py:3132

Methodcreate_test_runner

(cls, options: dict[str, Any])

src/anyio/_backends/_trio.py:1464

Methodcreate_udp_socket

( cls, family: AddressFamily, local_address: IPSockAddrType | None, remote_add

src/anyio/abc/_eventloop.py:271

Methodcreate_udp_socket

( cls, family: AddressFamily, local_address: IPSockAddrType | None, remote_add

src/anyio/_backends/_asyncio.py:2819

Methodcreate_unix_datagram_socket

( cls, raw_socket: socket, remote_path: None )

src/anyio/abc/_eventloop.py:282

Methodcreate_unix_datagram_socket

( # type: ignore[override] cls, raw_socket: socket.socket, remote_path: str | bytes | None )

src/anyio/_backends/_asyncio.py:2843

Methodcreate_unix_listener

(cls, sock: socket)

src/anyio/abc/_eventloop.py:266

Methodcreate_unix_listener

(cls, sock: socket.socket)

src/anyio/_backends/_asyncio.py:2815

Functioncurrent_default_thread_limiter

Return the capacity limiter that is used by default to limit the number of concurrent threads. :return: a capacity limiter object :r

src/anyio/to_thread.py:70

Methodcurrent_default_thread_limiter

(cls)

src/anyio/_backends/_trio.py:1419

Methodcurrent_effective_deadline

(cls)

src/anyio/_backends/_asyncio.py:2534

Methodcurrent_time

Return the current value of the event loop's internal clock. :return: the clock value (seconds)

src/anyio/abc/_eventloop.py:86

Methodcurrent_token

(cls)

src/anyio/_backends/_asyncio.py:2484

Methoddata_received

(self, data: bytes)

src/anyio/_backends/_asyncio.py:1263

Methoddatagram_received

(self, data: bytes, addr: IPSockAddrType)

src/anyio/_backends/_asyncio.py:1299

Functiondeactivate_blockbuster

(blockbuster: BlockBuster | None)

tests/conftest.py:128

Methoddeadline

The time (clock value) when this scope is cancelled automatically. Will be ``float('inf')`` if no timeout has been set.

src/anyio/_core/_tasks.py:72

Methoddeadline

(self)

src/anyio/_backends/_asyncio.py:668

Methoddeadline

(self)

src/anyio/_backends/_trio.py:170

Functiondestroy_workers

()

tests/test_to_interpreter.py:18

Functiondo_something

()

tests/test_taskgroups.py:1045

Functiondrain_stream

(stream: AsyncIterable[bytes], index: int)

src/anyio/_core/_subprocesses.py:75

Methoddrive

(self)

src/anyio/_core/_fileio.py:431

Functiondummy

()

tests/test_taskgroups.py:459

Methoddummy

()

tests/test_to_thread.py:349

Functioneager_task_loop_factory

src/anyio/_backends/_asyncio.py:1268

← previous next →801–900 of 2,163, ranked by callers