MCPcopy Create free account

hub / github.com/agronholm/anyio / functions

Functions2,163 in github.com/agronholm/anyio

Method_deliver
(self, signum: Signals)
src/anyio/_backends/_asyncio.py:2182
Function_do_shutdown
(future: asyncio.futures.Future)
src/anyio/_backends/_asyncio.py:283
Method_effectively_cancelled
(self)
src/anyio/_backends/_asyncio.py:552
Method_event
(self)
src/anyio/_core/_synchronization.py:125
Method_exception_handler
( self, loop: asyncio.AbstractEventLoop, context: dict[str, Any] )
src/anyio/_backends/_asyncio.py:2300
Function_flood_stderr
Helper that writes enough data to stderr to fill an undrained pipe buffer.
tests/test_to_process.py:61
Function_forcibly_shutdown_process_pool_on_exit
Forcibly shuts down worker processes belonging to this event loop.
src/anyio/_backends/_asyncio.py:1191
Function_identity
(v: _T)
tests/test_sockets.py:215
Function_interp_call
( func: Callable[..., Any], args: tuple[Any, ...] )
src/anyio/to_interpreter.py:28
Method_limiter
(self)
src/anyio/_core/_synchronization.py:657
Method_lock
(self)
src/anyio/_core/_synchronization.py:216
Method_main_task_finished
(self, outcome: object)
src/anyio/_backends/_trio.py:1001
Method_on_sigint
(self, signum, frame, main_task: asyncio.Task)
src/anyio/_backends/_asyncio.py:249
Function_operator_add
(x: T, y: T)
src/anyio/itertools.py:143
Method_parent_cancellation_is_visible_to_us
(self)
src/anyio/_backends/_asyncio.py:566
Method_raw_socket
(self)
src/anyio/abc/_sockets.py:174
Method_raw_socket
(self)
src/anyio/_backends/_asyncio.py:1323
Method_raw_socket
(self)
src/anyio/_backends/_asyncio.py:1413
Method_raw_socket
(self)
src/anyio/_backends/_asyncio.py:1577
Method_raw_socket
(self)
src/anyio/_backends/_asyncio.py:1660
Method_raw_socket
(self)
src/anyio/_backends/_asyncio.py:1675
Method_raw_socket
(self)
src/anyio/_backends/_asyncio.py:1725
Method_raw_socket
(self)
src/anyio/_backends/_trio.py:457
Method_relpath_list
( self, real_path: Path, path: AsyncIterable[Path] )
tests/test_fileio.py:470
Method_report_result
( self, future: asyncio.Future, result: Any, exc: BaseException | None )
src/anyio/_backends/_asyncio.py:1001
Method_run_tests_and_fixtures
(self)
src/anyio/_backends/_trio.py:988
Method_semaphore
(self)
src/anyio/_core/_synchronization.py:493
Function_shutdown_process_pool
(workers: set[abc.Process])
src/anyio/_backends/_trio.py:427
Method_stop
(self)
src/anyio/_core/_asyncio_selector_thread.py:48
Function_stop_workers
(workers: deque[_Worker])
src/anyio/to_interpreter.py:167
Methodaccept
(self)
src/anyio/_backends/_asyncio.py:1634
Methodaccept
(self)
src/anyio/_backends/_trio.py:600
Methodaclose
(self)
src/anyio/streams/stapled.py:55
Methodaclose
(self)
src/anyio/streams/stapled.py:91
Methodaclose
(self)
src/anyio/streams/text.py:67
Methodaclose
(self)
src/anyio/streams/text.py:103
Methodaclose
(self)
src/anyio/streams/memory.py:166
Methodaclose
(self)
src/anyio/streams/memory.py:297
Methodaclose
(self)
src/anyio/streams/buffered.py:41
Methodaclose
(self)
src/anyio/streams/tls.py:382
Methodaclose
(self)
src/anyio/streams/file.py:39
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1084
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1114
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1389
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1436
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1609
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1655
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1678
Methodaclose
(self)
src/anyio/_backends/_asyncio.py:1728
Methodaclose
(self)
src/anyio/_backends/_trio.py:340
Methodaclose
(self)
src/anyio/_backends/_trio.py:356
Methodaclose
(self)
src/anyio/_backends/_trio.py:460
Methodaclose
(self)
tests/streams/test_stapled.py:37
Methodaclose
(self)
tests/streams/test_stapled.py:126
Methodaclose
(self)
tests/streams/test_stapled.py:141
Methodacquire
Acquire the lock.
src/anyio/_core/_synchronization.py:236
Methodacquire
(self)
src/anyio/_core/_synchronization.py:501
Methodacquire
Acquire a token for the current task, waiting if necessary for one to become available.
src/anyio/_core/_synchronization.py:599
Methodacquire
(self)
src/anyio/_core/_synchronization.py:716
Methodacquire
(self)
src/anyio/_backends/_asyncio.py:1883
Methodacquire
(self)
src/anyio/_backends/_asyncio.py:1981
Methodacquire
()
tests/test_synchronization.py:514
Methodacquire
()
tests/test_synchronization.py:835
Methodacquire_nowait
Acquire the lock, without blocking. :raises ~anyio.WouldBlock: if the operation would block
src/anyio/_core/_synchronization.py:240
Methodacquire_nowait
Acquire the underlying lock, without blocking. :raises ~anyio.WouldBlock: if the operation would block
src/anyio/_core/_synchronization.py:436
Methodacquire_nowait
(self)
src/anyio/_core/_synchronization.py:504
Methodacquire_nowait
Acquire a token for the current task without waiting for one to become available. :raises ~anyio.WouldBlock: if there are no
src/anyio/_core/_synchronization.py:579
Methodacquire_nowait
(self)
src/anyio/_core/_synchronization.py:710
Methodacquire_nowait
(self)
src/anyio/_backends/_asyncio.py:1919
Methodacquire_nowait
(self)
src/anyio/_backends/_asyncio.py:2012
Methodacquire_nowait
(self)
src/anyio/_backends/_asyncio.py:2104
Methodacquire_on_behalf_of
(self, borrower: object)
src/anyio/_core/_synchronization.py:719
Methodacquire_on_behalf_of_nowait
(self, borrower: object)
src/anyio/_core/_synchronization.py:713
Methodacquirer
(scope: AbstractContextManager[CancelScope])
tests/test_synchronization.py:421
Methodafter_run
(self)
src/anyio/_backends/_trio.py:418
Methodalways_false
(value: int)
tests/test_itertools.py:508
Methodalways_true
(value: int)
tests/test_itertools.py:512
Methodanchor
(self)
src/anyio/_core/_fileio.py:439
Functionanyio_backend
(request: Any)
src/anyio/pytest_plugin.py:277
Functionanyio_backend
(request: SubRequest)
tests/conftest.py:134
Functionanyio_backend_name
(anyio_backend: Any)
src/anyio/pytest_plugin.py:282
Functionanyio_backend_options
(anyio_backend: Any)
src/anyio/pytest_plugin.py:290
Methodargs_iterable
(a: int, b: int)
tests/test_itertools.py:866
Functionasync_add
(a: int, b: int)
tests/test_from_thread.py:45
Functionasync_add
(value: str)
tests/test_taskgroups.py:68
Functionasync_error
(text: str, delay: float = 0.1)
tests/test_taskgroups.py:49
Methodasync_func
()
tests/test_from_thread.py:258
Methodasync_get_thread_id
()
tests/test_from_thread.py:435
Functionasync_time_bomb
()
tests/test_from_thread.py:127
Methodasyncfunc
()
tests/test_from_thread.py:178
Methodasyncgen
()
tests/test_functools.py:462
Methodasyncgen
()
tests/test_itertools.py:174
Methodasyncgen
()
tests/test_itertools.py:202
Functionasyncio_event_loop
()
tests/conftest.py:164
Methodavailable_tokens
The number of tokens currently available to be borrowed
src/anyio/_core/_synchronization.py:575
Methodavailable_tokens
(self)
src/anyio/_core/_synchronization.py:704
Methodavailable_tokens
(self)
src/anyio/_backends/_asyncio.py:2094
Methodavailable_tokens
(self)
src/anyio/_backends/_trio.py:887
Functionblockbuster
()
tests/conftest.py:106
Methodborrowed_tokens
The number of tokens that have currently been borrowed.
src/anyio/_core/_synchronization.py:570
← previousnext →701–800 of 2,163, ranked by callers