Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/agronholm/anyio
/ functions
Functions
2,163 in github.com/agronholm/anyio
⨍
Functions
2,163
◇
Types & classes
270
↳
Endpoints
11
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
Method
accept
(self)
src/anyio/_backends/_asyncio.py:1634
Method
accept
(self)
src/anyio/_backends/_trio.py:600
Method
aclose
(self)
src/anyio/streams/stapled.py:55
Method
aclose
(self)
src/anyio/streams/stapled.py:91
Method
aclose
(self)
src/anyio/streams/text.py:67
Method
aclose
(self)
src/anyio/streams/text.py:103
Method
aclose
(self)
src/anyio/streams/memory.py:166
Method
aclose
(self)
src/anyio/streams/memory.py:297
Method
aclose
(self)
src/anyio/streams/buffered.py:41
Method
aclose
(self)
src/anyio/streams/tls.py:382
Method
aclose
(self)
src/anyio/streams/file.py:39
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1084
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1114
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1389
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1436
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1609
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1655
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1678
Method
aclose
(self)
src/anyio/_backends/_asyncio.py:1728
Method
aclose
(self)
src/anyio/_backends/_trio.py:340
Method
aclose
(self)
src/anyio/_backends/_trio.py:356
Method
aclose
(self)
src/anyio/_backends/_trio.py:460
Method
aclose
(self)
tests/streams/test_stapled.py:37
Method
aclose
(self)
tests/streams/test_stapled.py:126
Method
aclose
(self)
tests/streams/test_stapled.py:141
Method
acquire
Acquire the lock.
src/anyio/_core/_synchronization.py:236
Method
acquire
(self)
src/anyio/_core/_synchronization.py:501
Method
acquire
Acquire a token for the current task, waiting if necessary for one to become available.
src/anyio/_core/_synchronization.py:599
Method
acquire
(self)
src/anyio/_core/_synchronization.py:716
Method
acquire
(self)
src/anyio/_backends/_asyncio.py:1883
Method
acquire
(self)
src/anyio/_backends/_asyncio.py:1981
Method
acquire
()
tests/test_synchronization.py:514
Method
acquire
()
tests/test_synchronization.py:835
Method
acquire_nowait
Acquire the lock, without blocking. :raises ~anyio.WouldBlock: if the operation would block
src/anyio/_core/_synchronization.py:240
Method
acquire_nowait
Acquire the underlying lock, without blocking. :raises ~anyio.WouldBlock: if the operation would block
src/anyio/_core/_synchronization.py:436
Method
acquire_nowait
(self)
src/anyio/_core/_synchronization.py:504
Method
acquire_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
Method
acquire_nowait
(self)
src/anyio/_core/_synchronization.py:710
Method
acquire_nowait
(self)
src/anyio/_backends/_asyncio.py:1919
Method
acquire_nowait
(self)
src/anyio/_backends/_asyncio.py:2012
Method
acquire_nowait
(self)
src/anyio/_backends/_asyncio.py:2104
Method
acquire_on_behalf_of
(self, borrower: object)
src/anyio/_core/_synchronization.py:719
Method
acquire_on_behalf_of_nowait
(self, borrower: object)
src/anyio/_core/_synchronization.py:713
Method
acquirer
(scope: AbstractContextManager[CancelScope])
tests/test_synchronization.py:421
Method
after_run
(self)
src/anyio/_backends/_trio.py:418
Method
always_false
(value: int)
tests/test_itertools.py:508
Method
always_true
(value: int)
tests/test_itertools.py:512
Method
anchor
(self)
src/anyio/_core/_fileio.py:439
Function
anyio_backend
(request: Any)
src/anyio/pytest_plugin.py:277
Function
anyio_backend
(request: SubRequest)
tests/conftest.py:134
Function
anyio_backend_name
(anyio_backend: Any)
src/anyio/pytest_plugin.py:282
Function
anyio_backend_options
(anyio_backend: Any)
src/anyio/pytest_plugin.py:290
Method
args_iterable
(a: int, b: int)
tests/test_itertools.py:866
Function
async_add
(a: int, b: int)
tests/test_from_thread.py:45
Function
async_add
(value: str)
tests/test_taskgroups.py:68
Function
async_error
(text: str, delay: float = 0.1)
tests/test_taskgroups.py:49
Method
async_func
()
tests/test_from_thread.py:258
Method
async_get_thread_id
()
tests/test_from_thread.py:435
Function
async_time_bomb
()
tests/test_from_thread.py:127
Method
asyncfunc
()
tests/test_from_thread.py:178
Method
asyncgen
()
tests/test_functools.py:462
Method
asyncgen
()
tests/test_itertools.py:174
Method
asyncgen
()
tests/test_itertools.py:202
Function
asyncio_event_loop
()
tests/conftest.py:164
Method
available_tokens
The number of tokens currently available to be borrowed
src/anyio/_core/_synchronization.py:575
Method
available_tokens
(self)
src/anyio/_core/_synchronization.py:704
Method
available_tokens
(self)
src/anyio/_backends/_asyncio.py:2094
Method
available_tokens
(self)
src/anyio/_backends/_trio.py:887
Function
blockbuster
()
tests/conftest.py:106
Method
borrowed_tokens
The number of tokens that have currently been borrowed.
src/anyio/_core/_synchronization.py:570
← previous
next →
701–800 of 2,163, ranked by callers