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
test_iterable_variants
(self)
tests/test_itertools.py:105
Function
test_iterate
()
tests/streams/test_memory.py:121
Method
test_iterate
( self, server_sock: socket.socket, server_addr: tuple[str, int] )
tests/test_sockets.py:344
Method
test_iterate
(self, server_sock: socket.socket, socket_path: Path)
tests/test_sockets.py:1403
Method
test_iterate
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:1806
Method
test_iterate
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:1979
Method
test_iterate
(self, peer_socket_path: Path, socket_path: Path)
tests/test_sockets.py:2163
Method
test_iterate
( self, socket_path: Path, peer_socket_path: Path, )
tests/test_sockets.py:2349
Method
test_iterdir
( self, populated_tmpdir: Path, limiter: CapacityLimiter | None )
tests/test_fileio.py:591
Method
test_joinpath
(self, limiter: CapacityLimiter | None)
tests/test_fileio.py:603
Function
test_keyboard_interrupt_does_not_resume_test
(testdir: Pytester)
tests/test_pytest_plugin.py:480
Function
test_keyboardinterrupt_during_test
( testdir: Pytester, anyio_backend_name: str )
tests/test_pytest_plugin.py:454
Method
test_lchmod
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:646
Function
test_level_cancellation
()
tests/test_taskgroups.py:456
Method
test_limit
(self)
tests/test_synchronization.py:745
Method
test_listening_bytes_path
(self, socket_path: Path)
tests/test_sockets.py:1664
Method
test_listening_invalid_ascii
(self, socket_path: Path)
tests/test_sockets.py:1671
Method
test_local_path_bytes
(self, socket_path: Path)
tests/test_sockets.py:2220
Method
test_local_path_invalid_ascii
(self, socket_path: Path)
tests/test_sockets.py:2229
Method
test_lock_granularity
Test that calls to the cached function with different arguments can occur concurrently and do not wait for a shared lock.
tests/test_functools.py:252
Method
test_loop_factory
(self)
tests/test_eventloop.py:108
Method
test_lru_eviction
(self)
tests/test_functools.py:168
Method
test_lstat
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:656
Function
test_main_task_name
( anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_debugging.py:28
Method
test_manual_acquire
(self)
tests/test_synchronization.py:50
Method
test_manual_acquire
(self)
tests/test_synchronization.py:364
Method
test_manual_acquire
(self)
tests/test_synchronization.py:525
Method
test_match
(self)
tests/test_fileio.py:616
Method
test_max_value
(self, max_value: int | None)
tests/test_synchronization.py:594
Method
test_max_value_exceeded
(self)
tests/test_synchronization.py:598
Function
test_memory_object_item_receiver_repr
Test the repr of `MemoryObjectItemReceiver`. Since when `item` is not set, the default dataclass repr raises an AttributeError.
tests/streams/test_memory.py:510
Method
test_mkdir
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:672
Function
test_mkdtemp
(prefix: AnyStr)
tests/test_tempfile.py:184
Function
test_mkstemp
( suffix: AnyStr, prefix: AnyStr, text: bool, content: AnyStr, )
tests/test_tempfile.py:153
Function
test_module_scoped_task_group_fixture
(testdir: Pytester)
tests/test_pytest_plugin.py:260
Method
test_move
( self, tmp_path: pathlib.Path, limiter: CapacityLimiter | None )
tests/test_fileio.py:426
Method
test_move_into
( self, tmp_path: pathlib.Path, limiter: CapacityLimiter | None )
tests/test_fileio.py:441
Function
test_move_on_after
(delay: float)
tests/test_taskgroups.py:718
Function
test_move_on_after_no_timeout
()
tests/test_taskgroups.py:729
Function
test_multi_listener
(tmp_path_factory: TempPathFactory)
tests/test_sockets.py:1689
Method
test_multiple_threads
( self, provider: BlockingPortalProvider, anyio_backend_name: str )
tests/test_to_thread.py:338
Method
test_n_one_creates_peekable_iterator
(self)
tests/test_itertools.py:963
Method
test_n_zero
(self)
tests/test_itertools.py:960
Method
test_name_property
(self)
tests/test_fileio.py:229
Method
test_named_temporary_file
(self)
tests/test_tempfile.py:37
Function
test_negative_max_buffer
()
tests/streams/test_memory.py:39
Method
test_negative_r
(self)
tests/test_itertools.py:290
Method
test_negative_r
(self)
tests/test_itertools.py:343
Method
test_negative_r
(self)
tests/test_itertools.py:727
Method
test_negative_repeat
(self)
tests/test_itertools.py:785
Function
test_nested_exception_group_filtering
Test that CancelledErrors are filtered out of nested exception groups containing other exceptions.
tests/test_taskgroups.py:1249
Function
test_nested_fail_after
()
tests/test_taskgroups.py:1101
Function
test_nested_move_on_after
()
tests/test_taskgroups.py:740
Function
test_nested_shield
()
tests/test_taskgroups.py:1121
Function
test_nested_task_group_filtering
Test that CancelledErrors are filtered out of nested exception groups from task groups.
tests/test_taskgroups.py:1183
Method
test_no_caching
(self, maxsize: int)
tests/test_functools.py:96
Function
test_no_called_started_twice
()
tests/test_taskgroups.py:183
Method
test_no_initial
(self)
tests/test_functools.py:437
Function
test_no_spin_on_done_task_in_cancel_scope
Regression test for #1111. When a task group is entered but never exited (e.g. it is abandoned because the task owning it finishes without un
tests/test_taskgroups.py:365
Method
test_non_coro
(self)
tests/test_taskgroups.py:2129
Function
test_non_main_task_name
( name_input: bytes | str | None, expected: str )
tests/test_debugging.py:62
Function
test_nonexistent_main_module
Test that worker process creation won't fail if the detected path to the `__main__` module doesn't exist. Regression test for #696.
tests/test_to_process.py:143
Function
test_not_closed_warning
()
tests/streams/test_memory.py:472
Method
test_not_iterable
(self)
tests/test_functools.py:431
Method
test_notification_handover_on_cancel
(self)
tests/test_synchronization.py:418
Method
test_nowait_acquire_after_release_does_not_oversubscribe
(self)
tests/test_synchronization.py:997
Method
test_open
( self, tmp_path: pathlib.Path, limiter: CapacityLimiter | None )
tests/test_fileio.py:677
Method
test_open_close
( self, testdatafile: pathlib.Path, limiter: CapacityLimiter | None )
tests/test_fileio.py:37
Function
test_open_process_connect_to_file
(tmp_path: Path)
tests/test_subprocesses.py:149
Method
test_ordered_queue
(self)
tests/test_synchronization.py:846
Function
test_outcome_exception_does_not_discard_runner_task
(testdir: Pytester)
tests/test_pytest_plugin.py:513
Method
test_owner
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:692
Method
test_owner_after_release
(self)
tests/test_synchronization.py:246
Method
test_parent_property
(self, limiter: CapacityLimiter | None)
tests/test_fileio.py:223
Method
test_parents_property
(self, limiter: CapacityLimiter | None)
tests/test_fileio.py:214
Function
test_partial
Test that partial() can be used to pass keyword arguments.
tests/test_to_process.py:39
Method
test_parts_property
(self)
tests/test_fileio.py:199
Method
test_pass_connectable
(self)
tests/test_sockets.py:2468
Function
test_patched_asyncio_task
(monkeypatch: MonkeyPatch)
tests/test_taskgroups.py:2015
Function
test_plugin
(testdir: Pytester)
tests/test_pytest_plugin.py:23
Function
test_print
Test that print() won't interfere with parent-worker communication.
tests/test_to_process.py:53
Function
test_process_aexit_cancellation_closes_standard_streams
Regression test for #669. Ensures that open_process.__aexit__() closes standard streams when cancelled. Also ensures that process.std{in
tests/test_subprocesses.py:255
Function
test_process_aexit_cancellation_doesnt_orphan_process
Regression test for #669. Ensures that open_process.__aexit__() doesn't leave behind an orphan process when cancelled.
tests/test_subprocesses.py:237
Function
test_process_cwd
Test that `cwd` is successfully passed to the subprocess implementation
tests/test_subprocesses.py:115
Function
test_process_env
Test that `env` is successfully passed to the subprocess implementation
tests/test_subprocesses.py:122
Function
test_process_new_session_sid
Test that start_new_session is successfully passed to the subprocess implementation.
tests/test_subprocesses.py:134
Function
test_process_receive_invalid_max_bytes
(max_bytes: int)
tests/test_subprocesses.py:104
Function
test_programmatic_anyio_mark
Test that the anyio marker added programmatically via pytest_collection_modifyitems causes the test to be run (regression test for issue #422).
tests/test_pytest_plugin.py:781
Function
test_propagate_native_cancellation_from_taskgroup
()
tests/test_taskgroups.py:304
Method
test_propagates_inner_exception
(self)
tests/test_itertools.py:241
Method
test_properties
Ensure that all public properties and methods are available on the async Path class.
tests/test_fileio.py:112
Method
test_ragged_eof_on_receive
( self, server_context: ssl.SSLContext, client_context: ssl.SSLContext )
tests/streams/test_tls.py:324
Method
test_ragged_eofs
( self, server_context: ssl.SSLContext, client_context: ssl.SSLContext, server
tests/streams/test_tls.py:270
Method
test_raise_baseexception_from_task
Test that when a task raises a BaseException, it does not trigger additional exceptions when trying to close the portal.
tests/test_from_thread.py:746
Method
test_read
(self, testdatafile: pathlib.Path, testdata: bytes)
tests/test_fileio.py:44
Method
test_read_after_close
(self, file_path: Path)
tests/streams/test_file.py:41
Method
test_read_bytes
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:712
Method
test_read_file
(self, file_path: Path)
tests/streams/test_file.py:36
Method
test_read_file_as_path
(self, file_path_or_str: Path | str)
tests/streams/test_file.py:32
Method
test_read_text
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:717
← previous
next →
1,701–1,800 of 2,163, ranked by callers