Functions — github.com/agronholm/anyio

CodeHub MCPcopy Create free account

hub / github.com/agronholm/anyio / functions

Functions2,163 in github.com/agronholm/anyio

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

Methodreturncode

src/anyio/_backends/_trio.py:401

src/anyio/_core/_fileio.py:435

Run the given coroutine function in an asynchronous event loop. The current thread must not be already running an event loop. :param fu

src/anyio/_core/_eventloop.py:38

Run the given coroutine function in an asynchronous event loop. The current thread must not be already running an event loop.

src/anyio/abc/_eventloop.py:54

src/anyio/_backends/_asyncio.py:1019

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

src/anyio/_backends/_asyncio.py:2450

Methodrun_async_cm

src/anyio/from_thread.py:137

Methodrun_async_from_thread

( cls, func: Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]], args: tuple[Unpa

src/anyio/_backends/_asyncio.py:2656

Methodrun_async_from_thread

( cls, func: Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]], args: tuple[Unpa

src/anyio/_backends/_trio.py:1177

Methodrun_asyncgen_fixture

( self, fixture_func: Callable[..., AsyncGenerator[T_Retval, Any]], kwargs: dict[str,

src/anyio/_backends/_asyncio.py:2366

Methodrun_asyncgen_fixture

( self, fixture_func: Callable[..., AsyncGenerator[T_Retval, Any]], kwargs: dict[str,

src/anyio/_backends/_trio.py:1028

Functionrun_blocking_portal

src/anyio/from_thread.py:533

Methodrun_coro_with_task_status

( *, task_status: trio.TaskStatus[Any] )

src/anyio/_backends/_trio.py:289

Methodrun_fixture

( self, fixture_func: Callable[..., Coroutine[Any, Any, T_Retval]], kwargs: dict[str,

src/anyio/_backends/_asyncio.py:2389

Methodrun_fixture

( self, fixture_func: Callable[..., Coroutine[Any, Any, T_Retval]], kwargs: dict[str,

src/anyio/_backends/_trio.py:1046

Methodrun_in_context

tests/test_from_thread.py:618

Functionrun_portal

src/anyio/from_thread.py:525

Functionrun_sync

Call the given function with the given arguments in a subinterpreter. .. warning:: On Python 3.13, the :mod:`concurrent.interpreters` module

src/anyio/to_interpreter.py:174

Functionrun_sync

Call the given function with the given arguments in a worker process. If the ``cancellable`` option is enabled and the task waiting for its

src/anyio/to_process.py:45

Methodrun_sync_from_thread

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

src/anyio/_backends/_asyncio.py:2691

Methodrun_sync_from_thread

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

src/anyio/_backends/_trio.py:1190

Methodrun_sync_in_worker_thread

( # type: ignore[return] cls, func: Callable[[Unpack[PosArgsT]], T_Retval], args: tup

src/anyio/_backends/_asyncio.py:2583

Methodrun_sync_in_worker_thread

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

src/anyio/_backends/_trio.py:1154

( self, test_func: Callable[..., Coroutine[Any, Any, Any]], kwargs: dict[str, Any] )

src/anyio/_backends/_asyncio.py:2400

( self, test_func: Callable[..., Coroutine[Any, Any, Any]], kwargs: dict[str, Any] )

src/anyio/_backends/_trio.py:1053

Functionrun_with_hypothesis

(**kwargs: Any)

src/anyio/pytest_plugin.py:241

Functionscoped_receiver

(task_status: TaskStatus[CancelScope])

tests/streams/test_memory.py:312

Functionsecond_func

tests/test_lowlevel.py:29

Functionsecond_func

tests/test_itertools.py:83

Seek the file to the given position. .. seealso:: :meth:`io.IOBase.seek` .. note:: Not all file descriptors are seekable.

src/anyio/streams/file.py:97

Functionself_cancel

(*, task_status: TaskStatus)

tests/test_debugging.py:149

tests/streams/test_memory.py:357

Send an item to the peer(s). :param item: the item to send :raises ~anyio.ClosedResourceError: if the send stream has been e

src/anyio/abc/_streams.py:63

Send the given bytes to the peer. :param item: the bytes to send

src/anyio/abc/_streams.py:155

(self, item: T_Item)

src/anyio/streams/stapled.py:85

Send an item to the stream. If the buffer is full, this method blocks until there is again room in the buffer or the item ca

src/anyio/streams/memory.py:235

(self, item: bytes)

src/anyio/streams/buffered.py:176

(self, item: bytes)

src/anyio/streams/file.py:151

(self, item: bytes)

src/anyio/_backends/_asyncio.py:1094

(self, item: bytes)

src/anyio/_backends/_asyncio.py:1364

(self, item: bytes)

src/anyio/_backends/_asyncio.py:1476

(self, item: bytes)

src/anyio/_backends/_asyncio.py:1754

(self, item: UNIXDatagramPacketType)

src/anyio/_backends/_asyncio.py:1784

(self, item: bytes)

src/anyio/_backends/_asyncio.py:1820

(self, item: bytes)

src/anyio/_backends/_trio.py:348

(self, item: bytes)

src/anyio/_backends/_trio.py:497

(self, item: bytes)

src/anyio/_backends/_trio.py:645

(self, item: bytes)

src/anyio/_backends/_trio.py:690

(self, item: T_Item)

tests/streams/test_stapled.py:135

Methodsend_data

tests/test_sockets.py:496

Methodsend_data

tests/test_sockets.py:1431

Send an end-of-file indication to the peer. You should not try to send any further data to this stream after calling this me

src/anyio/abc/_streams.py:109

Send an end-of-file indication to the peer. You should not try to send any further data to this stream after calling this me

src/anyio/abc/_streams.py:167

src/anyio/streams/stapled.py:52

src/anyio/streams/stapled.py:88

src/anyio/streams/text.py:150

src/anyio/_backends/_asyncio.py:1383

src/anyio/_backends/_asyncio.py:1449

src/anyio/_backends/_trio.py:508

(self, message: bytes, fds: Collection[int | IOBase])

src/anyio/_backends/_asyncio.py:1533

(self, message: bytes, fds: Collection[int | IOBase])

src/anyio/_backends/_trio.py:546

Methodsend_signal

Send a signal to the subprocess. .. seealso:: :meth:`subprocess.Popen.send_signal` :param signal: the signal number (e.g. :

src/anyio/abc/_subprocesses.py:44

Methodsend_signal

(self, signal: int)

src/anyio/_backends/_asyncio.py:1167

Methodsend_signal

(self, signal: Signals)

src/anyio/_backends/_trio.py:393

Methodsend_stream

tests/streams/test_stapled.py:58

Methodsend_stream

tests/streams/test_stapled.py:151

Alias for :meth:`~.UnreliableObjectSendStream.send` ((data, path)).

src/anyio/abc/_sockets.py:368

( self, handler: Callable[[SocketStream], Any], task_group: TaskGroup | None = None,

src/anyio/abc/_sockets.py:268

Accept incoming connections as they come in and start tasks to handle them. :param handler: a callable that will be used to handle e

src/anyio/abc/_streams.py:198

( self, handler: Callable[[T_Stream], Any], task_group: TaskGroup | None = None )

src/anyio/streams/stapled.py:131

( self, handler: Callable[[TLSStream], Any], task_group: TaskGroup | None = None,

src/anyio/streams/tls.py:359

tests/test_sockets.py:1250

tests/test_sockets.py:1807

tests/test_sockets.py:1980

tests/test_sockets.py:2164

tests/test_sockets.py:2354

tests/streams/test_tls.py:85

Methodserve_sync

tests/streams/test_tls.py:38

tests/streams/test_tls.py:614

Methodserver_addr

(self, server_sock: socket.socket)

tests/test_sockets.py:250

Functionserver_context

tests/conftest.py:144

Methodserver_sock

(self, family: AnyIPAddressFamily)

tests/test_sockets.py:242

Methodserver_sock

(self, socket_path: Path)

tests/test_sockets.py:1192

src/anyio/_core/_synchronization.py:133

Functionset_event

tests/test_taskgroups.py:1441

Functionset_result

tests/test_taskgroups.py:441

tests/test_synchronization.py:270

tests/test_synchronization.py:780

Methodsetup_process_pool_exit_at_shutdown

(cls, workers: set[abc.Process])

src/anyio/_backends/_asyncio.py:2768

Methodsetup_process_pool_exit_at_shutdown

(cls, workers: set[abc.Process])

src/anyio/_backends/_trio.py:1244

``True`` if this scope is shielded from external cancellation. While a scope is shielded, it will not receive cancellations from out

src/anyio/_core/_tasks.py:104

src/anyio/_backends/_asyncio.py:690

src/anyio/_backends/_trio.py:186

Functionshield_task

tests/test_taskgroups.py:325

Methodshield_task

tests/test_taskgroups.py:1674

Functionsignal_handler

tests/test_signals.py:39

(cls, delay: float)

src/anyio/_backends/_asyncio.py:2524

Functionsleep_and_raise

tests/test_taskgroups.py:417

Functionsleep_only

(task_status: TaskStatus[None])

tests/test_taskgroups.py:421

tests/test_functools.py:394

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