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
Function
test_cancel_native_future_tasks_cancel_scope
()
tests/test_taskgroups.py:1378
Method
test_cancel_portal_future
Regression test for #575.
tests/test_from_thread.py:783
Function
test_cancel_propagation
()
tests/test_taskgroups.py:555
Function
test_cancel_propagation_with_inner_spawn
()
tests/test_taskgroups.py:1289
Function
test_cancel_reason
()
tests/test_taskgroups.py:2035
Function
test_cancel_receive
()
tests/streams/test_memory.py:163
Function
test_cancel_scope_cleared
()
tests/test_taskgroups.py:648
Function
test_cancel_scope_in_another_task
()
tests/test_taskgroups.py:535
Function
test_cancel_scope_in_asyncgen_fixture
(testdir: Pytester)
tests/test_pytest_plugin.py:233
Function
test_cancel_scope_in_child_task
()
tests/test_taskgroups.py:1001
Function
test_cancel_send
()
tests/streams/test_memory.py:177
Function
test_cancel_shielded_checkpoint
(cancel: bool)
tests/test_lowlevel.py:42
Function
test_cancel_shielded_scope
()
tests/test_taskgroups.py:800
Function
test_cancel_shielding_start
Test that if the host task that has spawned a subtask via ``start()`` is cancelled, a shielded cancel scope in the child task will shield it
tests/test_taskgroups.py:2047
Function
test_cancel_twice
Test that the same task can receive two cancellations.
tests/test_taskgroups.py:568
Function
test_cancel_wait_on_thread
()
tests/test_to_thread.py:132
Function
test_cancel_with_nested_task_groups
Regression test for #695.
tests/test_taskgroups.py:317
Function
test_cancel_with_reason
()
tests/test_taskgroups.py:492
Function
test_cancel_worker_thread
Test that when a task running a worker thread is cancelled, the cancellation is not acted on until the thread finishes.
tests/test_to_thread.py:97
Method
test_cancelled_after_acquire
(self)
tests/test_synchronization.py:219
Method
test_cancelled_after_acquire
(self)
tests/test_synchronization.py:678
Function
test_cancelled_not_caught
()
tests/test_taskgroups.py:843
Function
test_cancelled_parent
()
tests/test_taskgroups.py:1057
Function
test_cancelled_raises_beyond_origin_shielded
()
tests/test_taskgroups.py:887
Function
test_cancelled_raises_beyond_origin_unshielded
()
tests/test_taskgroups.py:868
Function
test_cancelled_scope_based_checkpoint
Regression test closely related to #698.
tests/test_taskgroups.py:851
Function
test_cancelscope_exit_before_enter
Test that a RuntimeError is raised if one tries to exit a cancel scope before entering.
tests/test_taskgroups.py:1474
Function
test_cancelscope_exit_in_wrong_task
()
tests/test_taskgroups.py:1487
Function
test_cancelscope_propagation
()
tests/test_from_thread.py:126
Function
test_cancelscope_propagation_when_abandoned
()
tests/test_from_thread.py:138
Function
test_cancelscope_wrong_exit_order
Test that a RuntimeError is raised if the task tries to exit cancel scopes in the wrong order.
tests/test_taskgroups.py:1461
Method
test_cannot_connect
(self, socket_path: Path)
tests/test_sockets.py:1489
Function
test_checkpoint
(cancel: bool)
tests/test_lowlevel.py:66
Function
test_checkpoint_if_cancelled
(cancel: bool)
tests/test_lowlevel.py:17
Method
test_checkpoints
(self)
tests/test_itertools.py:398
Method
test_checkpoints
(self)
tests/test_itertools.py:816
Method
test_checkpoints_after_first_result
(self)
tests/test_itertools.py:300
Method
test_checkpoints_after_first_result
(self)
tests/test_itertools.py:358
Method
test_checkpoints_after_first_result
(self)
tests/test_itertools.py:742
Method
test_checkpoints_after_first_result
(self)
tests/test_itertools.py:800
Method
test_checkpoints_buffered_replay
(self)
tests/test_itertools.py:984
Method
test_checkpoints_empty_async_iterable
(self)
tests/test_functools.py:510
Method
test_checkpoints_empty_inputs
(self)
tests/test_itertools.py:137
Method
test_checkpoints_empty_inputs
(self)
tests/test_itertools.py:188
Method
test_checkpoints_empty_inputs
(self)
tests/test_itertools.py:251
Method
test_checkpoints_empty_inputs
(self)
tests/test_itertools.py:435
Method
test_checkpoints_empty_inputs
(self)
tests/test_itertools.py:564
Method
test_checkpoints_empty_iterable
(self)
tests/test_functools.py:500
Method
test_checkpoints_empty_iterable
(self)
tests/test_itertools.py:879
Method
test_checkpoints_empty_iterable
(self)
tests/test_itertools.py:979
Method
test_checkpoints_empty_result
(self)
tests/test_itertools.py:294
Method
test_checkpoints_empty_result
(self)
tests/test_itertools.py:355
Method
test_checkpoints_empty_result
(self)
tests/test_itertools.py:384
Method
test_checkpoints_empty_result
(self)
tests/test_itertools.py:736
Method
test_checkpoints_empty_result
(self)
tests/test_itertools.py:794
Method
test_checkpoints_empty_result_non_cancelled
(self)
tests/test_itertools.py:797
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:347
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:479
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:525
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:652
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:671
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:843
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:929
Method
test_checkpoints_empty_results
(self)
tests/test_itertools.py:1008
Method
test_checkpoints_initial_value
(self)
tests/test_itertools.py:142
Method
test_checkpoints_r_greater_than_pool
(self)
tests/test_itertools.py:297
Method
test_checkpoints_r_greater_than_pool
(self)
tests/test_itertools.py:739
Method
test_checkpoints_replay
(self)
tests/test_itertools.py:440
Method
test_chmod
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:623
Function
test_cleanup_after_native_cancel
Regression test for #832.
tests/test_taskgroups.py:830
Method
test_cleanup_method
(self)
tests/test_tempfile.py:124
Method
test_clock
Test that ``backend_options`` are passed to ``trio.run()``.
tests/test_eventloop.py:138
Function
test_clone
()
tests/streams/test_memory.py:191
Function
test_clone_closed
()
tests/streams/test_memory.py:206
Method
test_close_during_receive
(self, server_addr: tuple[str, int])
tests/test_sockets.py:523
Method
test_close_during_receive
( self, server_sock: socket.socket, socket_path: Path )
tests/test_sockets.py:1460
Method
test_close_during_receive
(self)
tests/test_sockets.py:1857
Method
test_close_during_receive
(self)
tests/test_sockets.py:2036
Method
test_close_during_receive
(self)
tests/test_sockets.py:2196
Method
test_close_during_receive
( self, peer_socket_path_or_str: Path | str, peer_sock: socket.socket )
tests/test_sockets.py:2392
Function
test_close_early
Regression test for #490.
tests/test_subprocesses.py:406
Method
test_close_from_other_task
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:933
Function
test_close_receive_after_send
()
tests/streams/test_memory.py:356
Function
test_close_receive_while_sending
()
tests/streams/test_memory.py:229
Function
test_close_send_while_receiving
()
tests/streams/test_memory.py:214
Function
test_close_while_reading
()
tests/test_subprocesses.py:418
Function
test_close_with_stdout_blocked_subprocess
Regression test for #1166. Test that closing a process unblocks a subprocess blocked on writing to stdout (because the pipe buffer is fu
tests/test_subprocesses.py:470
Method
test_closed_state
(self)
tests/test_tempfile.py:97
Method
test_comparison
(self)
tests/test_fileio.py:147
Method
test_concurrent_access
(self)
tests/test_functools.py:205
Method
test_concurrent_receive
(self, server_addr: tuple[str, int])
tests/test_sockets.py:510
Method
test_concurrent_receive
( self, server_sock: socket.socket, socket_path: Path )
tests/test_sockets.py:1445
Method
test_concurrent_receive
(self)
tests/test_sockets.py:1842
Method
test_concurrent_receive
(self)
tests/test_sockets.py:2021
Method
test_concurrent_receive
(self)
tests/test_sockets.py:2183
Method
test_concurrent_receive
( self, peer_socket_path: Path, peer_sock: socket.socket )
tests/test_sockets.py:2375
Method
test_concurrent_send
(self, server_addr: tuple[str, int])
tests/test_sockets.py:495
Method
test_concurrent_send
( self, server_sock: socket.socket, socket_path: Path )
tests/test_sockets.py:1428
Function
test_connect_tcp_getaddrinfo_context
See https://github.com/agronholm/anyio/issues/815
tests/test_sockets.py:2574
Method
test_connect_tcp_with_local_port
( self, server_sock: socket.socket, server_addr: tuple[str, int], family: AnyI
tests/test_sockets.py:411
← previous
next →
1,401–1,500 of 2,163, ranked by callers