MCPcopy Create free account

hub / github.com/agronholm/anyio / functions

Functions2,163 in github.com/agronholm/anyio

Methodtest_send_after_close
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:2057
Methodtest_send_after_close
(self, socket_path: Path)
tests/test_sockets.py:2213
Methodtest_send_after_close
( self, peer_socket_path_or_str: Path | str, peer_sock: socket.socket )
tests/test_sockets.py:2415
Methodtest_send_after_eof
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:948
Methodtest_send_after_eof
(self, socket_path: Path)
tests/test_sockets.py:1630
Methodtest_send_after_peer_closed
( self, family: AnyIPAddressFamily, request: FixtureRequest )
tests/test_sockets.py:562
Functiontest_send_encoding_error
()
tests/streams/test_text.py:57
Methodtest_send_eof
( self, server_sock: socket.socket, server_addr: tuple[str, int] )
tests/test_sockets.py:318
Methodtest_send_eof
( self, server_sock: socket.socket, socket_path: Path )
tests/test_sockets.py:1377
Methodtest_send_eof
(self, stapled: StapledByteStream)
tests/streams/test_stapled.py:83
Methodtest_send_eof
(self, stapled: StapledObjectStream[str])
tests/streams/test_stapled.py:175
Methodtest_send_eof_not_implemented
( self, server_context: ssl.SSLContext, ca: CA, force_tlsv12: bool )
tests/streams/test_tls.py:407
Methodtest_send_exception_cause_preserved
Test that when connection_lost is called with an exception, the resulting BrokenResourceError from send() has the original exception
tests/test_sockets.py:603
Methodtest_send_fds
( self, server_sock: socket.socket, socket_path: Path, tmp_path: Path )
tests/test_sockets.py:1341
Methodtest_send_fds_bad_args
( self, server_sock: socket.socket, socket_path: Path )
tests/test_sockets.py:1418
Functiontest_send_is_unblocked_after_receive_nowait
()
tests/streams/test_memory.py:94
Methodtest_send_large_buffer
( self, server_sock: socket.socket, server_addr: tuple[str, int] )
tests/test_sockets.py:295
Methodtest_send_large_buffer
( self, server_sock: socket.socket, socket_path: Path )
tests/test_sockets.py:1268
Functiontest_send_nowait_then_receive_nowait
()
tests/streams/test_memory.py:110
Methodtest_send_receive
( self, server_sock: socket.socket, server_addr: tuple[str, int] )
tests/test_sockets.py:272
Methodtest_send_receive
( self, server_sock: socket.socket, socket_path_or_str: Path | str )
tests/test_sockets.py:1224
Methodtest_send_receive
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:1789
Methodtest_send_receive
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:1958
Methodtest_send_receive
(self, socket_path_or_str: Path | str)
tests/test_sockets.py:2141
Methodtest_send_receive
( self, socket_path_or_str: Path | str, peer_socket_path_or_str: Path | str, )
tests/test_sockets.py:2327
Methodtest_send_receive
( self, server_context: ssl.SSLContext, client_context: ssl.SSLContext )
tests/streams/test_tls.py:35
Functiontest_send_then_receive_nowait
()
tests/streams/test_memory.py:83
Functiontest_send_to_natively_cancelled_receiver
Test that if a task waiting on receive.receive() is cancelled and then another task sends an item, said item is not delivered to the task wit
tests/streams/test_memory.py:489
Functiontest_send_when_cancelled
Test that calling send() in a cancelled scope prevents it from going through with the operation.
tests/streams/test_memory.py:279
Functiontest_shielded_cancel_sleep_time
Test that cancelling a shielded tasks spends more time sleeping than cancelling.
tests/test_taskgroups.py:1433
Functiontest_shielded_cleanup_after_cancel
Regression test for #832.
tests/test_taskgroups.py:811
Functiontest_shielded_deadline
()
tests/test_taskgroups.py:1073
Functiontest_shielding
()
tests/test_taskgroups.py:759
Functiontest_shielding_immediate_scope_cancelled
()
tests/test_taskgroups.py:961
Functiontest_shielding_mutate
()
tests/test_taskgroups.py:976
Methodtest_shorter_selectors
(self)
tests/test_itertools.py:378
Functiontest_single_cancellation_exc
Test that only a single cancellation exception bubbles out of the task group when case it was cancelled via an outer scope and no actual erro
tests/test_taskgroups.py:1526
Methodtest_single_thread
( self, provider: BlockingPortalProvider, anyio_backend_name: str )
tests/test_to_thread.py:303
Methodtest_single_thread_overlapping
( self, provider: BlockingPortalProvider, anyio_backend_name: str )
tests/test_to_thread.py:320
Methodtest_skips_empty_iterables
(self)
tests/test_itertools.py:234
Functiontest_sleep_forever
(fake_sleep: AsyncMock)
tests/test_eventloop.py:43
Functiontest_sleep_until
(fake_sleep: AsyncMock)
tests/test_eventloop.py:31
Functiontest_sleep_until_in_past
(fake_sleep: AsyncMock)
tests/test_eventloop.py:37
Methodtest_sniffio
(self, anyio_backend_name: str)
tests/test_from_thread.py:268
Methodtest_sniffio
(self, anyio_backend_name: str)
tests/test_from_thread.py:326
Methodtest_socket_options
( self, family: AnyIPAddressFamily, server_addr: tuple[str, int] )
tests/test_sockets.py:366
Methodtest_socket_options
(self, family: AnyIPAddressFamily)
tests/test_sockets.py:870
Methodtest_socket_options
(self, socket_path: Path)
tests/test_sockets.py:1611
Functiontest_start_already_closed
()
tests/test_taskgroups.py:117
Functiontest_start_called_twice
()
tests/test_taskgroups.py:139
Functiontest_start_cancel_after_error
Regression test for #517.
tests/test_taskgroups.py:413
Functiontest_start_cancelled
()
tests/test_taskgroups.py:238
Functiontest_start_cancels_parent_scope
Regression test for #685 / #710.
tests/test_taskgroups.py:1787
Functiontest_start_crash_after_started_call
()
tests/test_taskgroups.py:213
Methodtest_start_crash_after_started_call
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:675
Functiontest_start_crash_before_started_call
()
tests/test_taskgroups.py:202
Methodtest_start_crash_before_started_call
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:665
Functiontest_start_exception_delivery
(return_handle: bool)
tests/test_taskgroups.py:400
Functiontest_start_native_child_cancelled
()
tests/test_taskgroups.py:280
Functiontest_start_native_host_cancelled
()
tests/test_taskgroups.py:256
Functiontest_start_no_started_call
()
tests/test_taskgroups.py:227
Methodtest_start_no_started_call
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:688
Functiontest_start_no_value
()
tests/test_taskgroups.py:130
Methodtest_start_no_value
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:631
Methodtest_start_non_corofunc
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:653
Functiontest_start_parent_id
()
tests/test_taskgroups.py:1565
Functiontest_start_return_handle_cancel
()
tests/test_taskgroups.py:1817
Functiontest_start_return_handle_success
()
tests/test_taskgroups.py:1805
Functiontest_start_soon_after_error
()
tests/test_taskgroups.py:106
Functiontest_start_soon_parent_id
()
tests/test_taskgroups.py:1548
Functiontest_start_soon_while_running
()
tests/test_taskgroups.py:98
Functiontest_start_sync_wrapper
()
tests/test_taskgroups.py:153
Functiontest_start_sync_wrapper_called_twice
()
tests/test_taskgroups.py:167
Methodtest_start_task_soon
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:477
Methodtest_start_task_soon_cancel_after_stop
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:539
Methodtest_start_task_soon_cancel_immediately
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:517
Methodtest_start_task_soon_cancel_later
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:504
Methodtest_start_task_soon_non_corofunc
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:493
Methodtest_start_task_soon_with_name
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:563
Methodtest_start_with_name
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:698
Methodtest_start_with_new_event_loop
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:432
Methodtest_start_with_nonexistent_backend
(self)
tests/test_from_thread.py:460
Methodtest_start_with_thread_name
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:444
Functiontest_start_with_value
()
tests/test_taskgroups.py:193
Methodtest_start_with_value
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:642
Methodtest_start_without_thread_name
( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] )
tests/test_from_thread.py:452
Methodtest_stat
(self, tmp_path: pathlib.Path)
tests/test_fileio.py:788
Functiontest_statistics
()
tests/streams/test_memory.py:374
Methodtest_statistics
(self)
tests/test_synchronization.py:151
Methodtest_statistics
(self)
tests/test_synchronization.py:318
Methodtest_statistics
(self)
tests/test_synchronization.py:443
Methodtest_statistics
(self)
tests/test_synchronization.py:603
Methodtest_statistics
(self)
tests/test_synchronization.py:809
Functiontest_stderr_flood
Test that writing large amounts of data to stderr in the worker process won't deadlock the call. Regression test for the worker's stderr not
tests/test_to_process.py:74
Functiontest_stdin_input_both_passed
(tmp_path: Path)
tests/test_subprocesses.py:214
Methodtest_stem_property
(self)
tests/test_fileio.py:238
Methodtest_stepwise
(self)
tests/test_itertools.py:272
Methodtest_stepwise
(self)
tests/test_itertools.py:315
Functiontest_stopiteration
Test that raising StopIteration in a worker thread raises a RuntimeError on the caller.
tests/test_to_thread.py:280
Methodtest_strict_complete_batch
(self)
tests/test_itertools.py:164
← previousnext →1,901–2,000 of 2,163, ranked by callers