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

Methodsocket_path

(self, request: SubRequest)

tests/test_sockets.py:1178

Methodsocket_path

(self, request: SubRequest)

tests/test_sockets.py:1566

Methodsocket_path

(self, request: SubRequest)

tests/test_sockets.py:2103

Methodsocket_path

(self, request: SubRequest)

tests/test_sockets.py:2261

Methodsocket_path_or_str

(self, request: SubRequest, socket_path: Path)

tests/test_sockets.py:1188

Methodsocket_path_or_str

(self, request: SubRequest, socket_path: Path)

tests/test_sockets.py:1576

Methodsocket_path_or_str

(self, request: SubRequest, socket_path: Path)

tests/test_sockets.py:2113

Methodsocket_path_or_str

(self, request: SubRequest, socket_path: Path)

tests/test_sockets.py:2271

( self, send_stream: DummyByteSendStream, receive_stream: DummyByteReceiveStream )

tests/streams/test_stapled.py:66

( self, receive_stream: DummyObjectReceiveStream[str], send_stream: DummyObjectSendStr

tests/streams/test_stapled.py:155

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

src/anyio/_backends/_trio.py:280

Methodstart_value

The value passed to :meth:`task_status.started() <.abc.TaskStatus.started>`, :raises RuntimeError: if the task was not started with

src/anyio/_core/_tasks.py:381

(self, value: object = None)

src/anyio/from_thread.py:181

(self, value: object = None)

src/anyio/_core/_tasks.py:38

(self, value: T_contra | None = None)

src/anyio/_backends/_asyncio.py:732

Functionstarter_task

tests/test_taskgroups.py:1556

Methodstatistics

Return statistics about the current state of this event.

src/anyio/_core/_synchronization.py:109

Methodstatistics

src/anyio/_core/_synchronization.py:148

Methodstatistics

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

src/anyio/_core/_synchronization.py:257

Methodstatistics

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

src/anyio/_core/_synchronization.py:459

Methodstatistics

src/anyio/_core/_synchronization.py:521

Methodstatistics

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

src/anyio/_core/_synchronization.py:636

Methodstatistics

src/anyio/_core/_synchronization.py:728

Methodstatistics

src/anyio/streams/memory.py:68

Methodstatistics

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

src/anyio/streams/memory.py:169

Methodstatistics

src/anyio/_backends/_asyncio.py:1868

Methodstatistics

src/anyio/_backends/_asyncio.py:1951

Methodstatistics

src/anyio/_backends/_asyncio.py:2040

Methodstatistics

src/anyio/_backends/_asyncio.py:2157

The current status of the task. Every task starts in the :attr:`~TaskHandle.Status.PENDING` state. If a task is cancelled wh

src/anyio/_core/_tasks.py:307

The stream for the standard error output of the process.

src/anyio/abc/_subprocesses.py:78

src/anyio/_backends/_asyncio.py:1187

src/anyio/_backends/_trio.py:413

The stream for the standard input of the process.

src/anyio/abc/_subprocesses.py:68

src/anyio/_backends/_asyncio.py:1179

src/anyio/_backends/_trio.py:405

The stream for the standard output of the process.

src/anyio/abc/_subprocesses.py:73

src/anyio/_backends/_asyncio.py:1183

src/anyio/_backends/_trio.py:409

src/anyio/_core/_fileio.py:463

Functionsubgroup

tests/test_taskgroups.py:597

Functionsubtask

tests/test_taskgroups.py:1552

src/anyio/_core/_fileio.py:455

src/anyio/_core/_fileio.py:459

Functionsuppress_slow_callbacks

tests/conftest.py:95

Functionsync_add

(a: int, b: int)

tests/test_from_thread.py:54

Functionsync_coro

tests/test_taskgroups.py:1986

Functionsync_function

tests/test_from_thread.py:75

Methodsync_thread

tests/test_from_thread.py:787

(task_status: TaskStatus)

tests/test_taskgroups.py:979

tests/test_synchronization.py:34

tests/test_synchronization.py:284

tests/test_synchronization.py:399

(*, task_status: TaskStatus)

tests/test_synchronization.py:571

Methodtask_done

(future: Future[T_Retval])

src/anyio/from_thread.py:408

Functiontask_fn

(*, task_status: TaskStatus[str] = TASK_STATUS_IGNORED)

tests/test_taskgroups.py:401

Functiontask_func

tests/test_taskgroups.py:99

Functiontask_worker

tests/test_to_thread.py:71

Functiontask_wrap

tests/test_taskgroups.py:1417

Methodtask_wrapper

src/anyio/_backends/_asyncio.py:2662

tests/test_lowlevel.py:95

tests/test_from_thread.py:497

tests/test_taskgroups.py:1700

tests/test_taskgroups.py:2121

tests/test_synchronization.py:748

Methodtaskfunc1

tests/test_synchronization.py:247

Return the current stream position. .. note:: Not all file descriptors are seekable. :return: the current absolute position

src/anyio/streams/file.py:113

Methodterminate

Terminates the process, gracefully if possible. On Windows, this calls ``TerminateProcess()``. On POSIX systems, this sends

src/anyio/abc/_subprocesses.py:22

Methodterminate

src/anyio/_backends/_asyncio.py:1161

Methodtest_absolute

(self, limiter: CapacityLimiter | None)

tests/test_fileio.py:241

Methodtest_accept

(self, family: AnyIPAddressFamily)

tests/test_sockets.py:831

Methodtest_accept

(self, socket_path_or_str: Path | str)

tests/test_sockets.py:1599

Methodtest_accept_after_close

(self, family: AnyIPAddressFamily)

tests/test_sockets.py:860

Methodtest_aclose

(self, stapled: StapledByteStream)

tests/streams/test_stapled.py:91

Methodtest_aclose

(self, stapled: StapledObjectStream[str])

tests/streams/test_stapled.py:184

Methodtest_aclose_waits_for_fd_release

Regression: ``UDPSocket.aclose`` must not return before the FD is released. ``AsyncResource.aclose`` is documented as "close the resource".

tests/test_sockets.py:1738

Methodtest_aclose_waits_for_fd_release

Regression: ``ConnectedUDPSocket.aclose`` must not return before the FD is released. Same race as ``UDPSocket.aclose``; see that test for the

tests/test_sockets.py:1919

Methodtest_acquire_cancelled

tests/test_synchronization.py:951

Methodtest_acquire_nowait

tests/test_synchronization.py:91

Methodtest_acquire_nowait

tests/test_synchronization.py:382

Methodtest_acquire_nowait

tests/test_synchronization.py:558

Methodtest_acquire_nowait

tests/test_synchronization.py:980

Methodtest_acquire_nowait_wouldblock

tests/test_synchronization.py:96

Methodtest_acquire_nowait_wouldblock

tests/test_synchronization.py:387

Methodtest_acquire_on_behalf_of_nowait

tests/test_synchronization.py:990

Methodtest_acquire_race

Test against a race condition: when a task waiting on acquire() is rescheduled but another task snatches the last available slot, the

tests/test_synchronization.py:620

Methodtest_acquire_twice_async

(self, fast_acquire: bool)

tests/test_synchronization.py:106

Methodtest_acquire_twice_sync

tests/test_synchronization.py:114

Methodtest_aexit_with_exception

Test that when the portal exits with an exception, all tasks are cancelled.

tests/test_from_thread.py:370

Methodtest_aexit_without_exception

Test that when the portal exits, it waits for all tasks to finish.

tests/test_from_thread.py:402

Functiontest_all_attributes

Check that all exported functions and classes of all public modules are present in the __all__ attribute of the module.

tests/test_all_attributes.py:13

Methodtest_alpn_negotiation

( self, server_context: ssl.SSLContext, client_context: ssl.SSLContext )

tests/streams/test_tls.py:229

Functiontest_already_closed

tests/test_taskgroups.py:57

Methodtest_always_checkpoint

tests/test_functools.py:272

Methodtest_anchor_property

tests/test_fileio.py:211

Methodtest_append_file

(self, file_path: Path)

tests/streams/test_file.py:91

Functiontest_args_kwargs

Test that partial() can be used to pass keyword arguments.

tests/test_to_interpreter.py:42

Methodtest_args_kwargs_cache_key

tests/test_functools.py:222

Functiontest_arguments_passed_through

Regression test ensuring all arguments accepted by ``open_process()`` are passed through to the backend's ``open_process()``.

tests/test_subprocesses.py:379

Methodtest_as_posix

tests/test_fileio.py:250

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