MCPcopy Create free account

hub / github.com/agronholm/anyio / functions

Functions2,270 in github.com/agronholm/anyio

↓ 1 callersMethodget_running_tasks
(cls)
src/anyio/_backends/_trio.py:1446
↓ 1 callersMethodgetaddrinfo
( cls, host: bytes | str | None, port: str | int | None, *, family: in
src/anyio/abc/_eventloop.py:319
↓ 1 callersMethodgetaddrinfo
( cls, host: bytes | str | None, port: str | int | None, *, family: in
src/anyio/_backends/_trio.py:1336
↓ 1 callersFunctiongetnameinfo
Look up the host name of an IP address. :param sockaddr: socket address (e.g. (ipaddress, port) for IPv4) :param flags: flags to pass to
src/anyio/_core/_sockets.py:668
↓ 1 callersMethodgetnameinfo
( cls, sockaddr: IPSockAddrType, flags: int = 0 )
src/anyio/abc/_eventloop.py:341
↓ 1 callersMethodgetnameinfo
( cls, sockaddr: IPSockAddrType, flags: int = 0 )
src/anyio/_backends/_trio.py:1357
↓ 1 callersFunctiongettempdir
Asynchronously return the name of the directory used for temporary files. This function wraps `tempfile.gettempdir` and executes it in a bac
src/anyio/_core/_tempfile.py:594
↓ 1 callersFunctiongettempdirb
Asynchronously return the name of the directory used for temporary files in bytes. This function wraps `tempfile.gettempdirb` and executes i
src/anyio/_core/_tempfile.py:606
↓ 1 callersMethodhandle_handshake_error
Handle an exception raised during the TLS handshake. This method does 3 things: #. Forcefully closes the original stream
src/anyio/streams/tls.py:328
↓ 1 callersMethodhardlink_to
( self, target: str | bytes | PathLike[str] | PathLike[bytes] )
src/anyio/_core/_fileio.py:652
↓ 1 callersMethodhome
(cls, *, limiter: CapacityLimiter | None = None)
src/anyio/_core/_fileio.py:661
↓ 1 callersFunctionhost_agen_fn
()
tests/test_taskgroups.py:1069
↓ 1 callersFunctionhost_task
()
tests/test_taskgroups.py:1056
↓ 1 callersFunctioninner_wrapper
()
src/anyio/_backends/_trio.py:127
↓ 1 callersMethodinstance_method
(self, x: int)
tests/test_functools.py:333
↓ 1 callersMethodis_absolute
(self)
src/anyio/_core/_fileio.py:665
↓ 1 callersMethodis_block_device
(self)
src/anyio/_core/_fileio.py:668
↓ 1 callersMethodis_char_device
(self)
src/anyio/_core/_fileio.py:673
↓ 1 callersMethodis_fifo
(self)
src/anyio/_core/_fileio.py:694
↓ 1 callersMethodis_junction
(self)
src/anyio/_core/_fileio.py:717
↓ 1 callersMethodis_mount
(self)
src/anyio/_core/_fileio.py:722
↓ 1 callersMethodis_relative_to
(self, other: str | PathLike[str])
src/anyio/_core/_fileio.py:562
↓ 1 callersMethodis_reserved
(self)
src/anyio/_core/_fileio.py:729
↓ 1 callersMethodis_running
Check if the test runner is running. :return: ``True`` if the coroutine is currently being run, ``False`` otherwise.
src/anyio/abc/_testing.py:74
↓ 1 callersMethodis_socket
(self)
src/anyio/_core/_fileio.py:732
↓ 1 callersFunctioniterate_exceptions
( exception: BaseException, )
src/anyio/_core/_exceptions.py:83
↓ 1 callersMethoditerdir
(self)
src/anyio/_core/_fileio.py:742
↓ 1 callersMethodlchmod
(self, mode: int)
src/anyio/_core/_fileio.py:756
↓ 1 callersMethodlocked
(self)
src/anyio/_backends/_asyncio.py:2000
↓ 1 callersFunctionmiddle_task
()
tests/test_taskgroups.py:395
↓ 1 callersFunctionmkdtemp
( suffix: str | None = None, prefix: str | None = None, dir: str | None = None, )
src/anyio/_core/_tempfile.py:560
↓ 1 callersFunctionmkstemp
( suffix: str | None = None, prefix: str | None = None, dir: str | None = None, text: bool = F
src/anyio/_core/_tempfile.py:520
↓ 1 callersMethodmove
(self, target: str | os.PathLike[str])
src/anyio/_core/_fileio.py:541
↓ 1 callersMethodmove_into
( self, target_dir: str | os.PathLike[str], )
src/anyio/_core/_fileio.py:551
↓ 1 callersFunctionnative_coro_part
()
tests/test_debugging.py:114
↓ 1 callersFunctionnative_coro_part
()
tests/test_taskgroups.py:1446
↓ 1 callersFunctionnever
()
tests/test_concurrency_utils.py:103
↓ 1 callersFunctionnormalize_index
(value: object, message: str)
src/anyio/itertools.py:413
↓ 1 callersMethodnotify_closing
(cls, obj: FileDescriptorLike)
src/anyio/_backends/_trio.py:1381
↓ 1 callersMethodopen_process
( cls, command: StrOrBytesPath | Sequence[StrOrBytesPath], *, stdin: int | IO[
src/anyio/_backends/_trio.py:1208
↓ 1 callersFunctionowner
()
tests/test_taskgroups.py:439
↓ 1 callersFunctionprocess_worker
()
src/anyio/to_process.py:207
↓ 1 callersMethodread
(self, size: int = -1)
src/anyio/_core/_tempfile.py:338
↓ 1 callersMethodreadline
(self)
src/anyio/_core/_fileio.py:125
↓ 1 callersMethodreadlink
(self)
src/anyio/_core/_fileio.py:870
↓ 1 callersMethodreceive
Receive the next item. :raises ~anyio.ClosedResourceError: if the receive stream has been explicitly closed :rai
src/anyio/abc/_streams.py:42
↓ 1 callersMethodreceive
Receive at most ``max_bytes`` bytes from the peer. .. note:: Implementers of this interface should not return an empty :
src/anyio/abc/_streams.py:138
↓ 1 callersMethodreceive
(self, max_bytes: int = 65536)
src/anyio/streams/stapled.py:43
↓ 1 callersMethodreceive
(self, max_bytes: int = 65536)
src/anyio/streams/tls.py:250
↓ 1 callersMethodrelease
Increment the semaphore value.
src/anyio/_core/_synchronization.py:451
↓ 1 callersMethodrelease
(self)
src/anyio/_backends/_asyncio.py:2003
↓ 1 callersMethodrelease
(self)
src/anyio/_backends/_asyncio.py:2088
↓ 1 callersMethodrelease
(self)
src/anyio/_backends/_trio.py:913
↓ 1 callersMethodrelease_on_behalf_of
Release the token held by the given borrower. :raises RuntimeError: if the borrower has not borrowed a token from this l
src/anyio/_core/_synchronization.py:632
↓ 1 callersMethodrelease_on_behalf_of
(self, borrower: object)
src/anyio/_backends/_asyncio.py:2216
↓ 1 callersMethodrelease_on_behalf_of
(self, borrower: object)
src/anyio/_backends/_trio.py:916
↓ 1 callersMethodrename
(self, target: str | pathlib.PurePath | Path)
src/anyio/_core/_fileio.py:876
↓ 1 callersMethodreplace
(self, target: str | pathlib.PurePath | Path)
src/anyio/_core/_fileio.py:883
↓ 1 callersFunctionreset_current_async_library
(token: Token | None)
src/anyio/_core/_eventloop.py:238
↓ 1 callersMethodresolve
(self, strict: bool = False)
src/anyio/_core/_fileio.py:890
↓ 1 callersFunctionreturn_non_coro_awaitable
( func: Callable[P, Coroutine[Any, Any, T]], )
tests/conftest.py:198
↓ 1 callersFunctionreturn_now
()
tests/test_concurrency_utils.py:100
↓ 1 callersMethodrmdir
(self)
src/anyio/_core/_fileio.py:930
↓ 1 callersMethodrollover
(self)
src/anyio/_core/_tempfile.py:321
↓ 1 callersMethodrun
(self)
src/anyio/_core/_asyncio_selector_thread.py:130
↓ 1 callersMethodrun_async_from_thread
( cls, func: Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]], args: tuple[Unpa
src/anyio/abc/_eventloop.py:219
↓ 1 callersMethodrun_asyncgen_fixture
Run an async generator fixture. :param fixture_func: the fixture function :param kwargs: keyword arguments to call the fixtu
src/anyio/abc/_testing.py:35
↓ 1 callersMethodrun_fixture
Run an async fixture. :param fixture_func: the fixture function :param kwargs: keyword arguments to call the fixture functio
src/anyio/abc/_testing.py:49
↓ 1 callersFunctionrun_in_thread
()
tests/test_to_thread.py:233
↓ 1 callersFunctionrun_sync
Call the given function with the given arguments in a worker thread. If the ``abandon_on_cancel`` option is enabled and the task waiting for
src/anyio/to_thread.py:27
↓ 1 callersMethodrun_sync_from_thread
( cls, func: Callable[[Unpack[PosArgsT]], T_Retval], args: tuple[Unpack[PosArgsT]],
src/anyio/abc/_eventloop.py:229
↓ 1 callersMethodrun_sync_in_worker_thread
( cls, func: Callable[[Unpack[PosArgsT]], T_Retval], args: tuple[Unpack[PosArgsT]],
src/anyio/abc/_eventloop.py:203
↓ 1 callersMethodsamefile
(self, other_path: str | PathLike[str])
src/anyio/_core/_fileio.py:933
↓ 1 callersMethodseek
(self, offset: int, whence: int | None = os.SEEK_SET)
src/anyio/_core/_tempfile.py:380
↓ 1 callersMethodsend
(self, item: bytes)
src/anyio/streams/stapled.py:49
↓ 1 callersMethodsend
(self, item: UNIXDatagramPacketType)
src/anyio/_backends/_trio.py:672
↓ 1 callersMethodsend_eof
(self)
src/anyio/streams/buffered.py:172
↓ 1 callersMethodsend_nowait
Send an item immediately if it can be done without waiting. :param item: the item to send :raises ~anyio.ClosedResourceError
src/anyio/streams/memory.py:206
↓ 1 callersFunctionsend_raw_command
(pickled_cmd: bytes)
src/anyio/to_process.py:70
↓ 1 callersMethodserve
()
tests/test_sockets.py:280
↓ 1 callersMethodsetup_process_pool_exit_at_shutdown
(cls, workers: set[Process])
src/anyio/abc/_eventloop.py:262
↓ 1 callersFunctionsetup_raw_socket
( fam: AddressFamily, bind_addr: tuple[str, int] | tuple[str, int, int, int], *,
src/anyio/_core/_sockets.py:329
↓ 1 callersFunctionsleep_sync
()
tests/test_to_thread.py:285
↓ 1 callersMethodsleep_until_stopped
Sleep until :meth:`stop` is called.
src/anyio/from_thread.py:222
↓ 1 callersMethodstart
(self)
src/anyio/_core/_asyncio_selector_thread.py:44
↓ 1 callersFunctionstart_another
()
tests/test_taskgroups.py:321
↓ 1 callersMethodstarted
(self, value: T_contra | None = None)
src/anyio/_backends/_trio.py:209
↓ 1 callersMethodstatic_method
(x: int)
tests/test_functools.py:308
↓ 1 callersMethodstatistics
Return statistics about the current state of this stream. .. versionadded:: 3.0
src/anyio/streams/memory.py:300
↓ 1 callersMethodstop
(self, f: asyncio.Task | None = None)
src/anyio/_backends/_asyncio.py:1119
↓ 1 callersMethodtask_done
(_task: asyncio.Task)
src/anyio/_backends/_asyncio.py:870
↓ 1 callersFunctiontask_func
()
tests/test_taskgroups.py:104
↓ 1 callersFunctiontaskfunc1
()
tests/test_to_thread.py:326
↓ 1 callersFunctiontaskfunc2
()
tests/test_to_thread.py:331
↓ 1 callersMethodtell
(self)
src/anyio/_core/_fileio.py:167
↓ 1 callersMethodtell
(self)
src/anyio/_core/_tempfile.py:387
↓ 1 callersFunctiontestfunc
()
tests/test_taskgroups.py:92
↓ 1 callersMethodwait
Wait for the task to finish. This method will return as soon as the task has finished, no matter how it happened.
src/anyio/_core/_tasks.py:447
↓ 1 callersMethodwait
(self)
src/anyio/_backends/_asyncio.py:1226
↓ 1 callersMethodwait
(self)
src/anyio/_backends/_trio.py:389
← previousnext →401–500 of 2,270, ranked by callers