MCPcopy Create free account

hub / github.com/agronholm/anyio / functions

Functions2,270 in github.com/agronholm/anyio

↓ 2 callersMethodstart
( self, func: Callable[[Unpack[PosArgsT]], Coroutine[Any, Any, T_co]], *args: Unpack[P
src/anyio/_backends/_asyncio.py:987
↓ 2 callersMethodstatistics
Return statistics about the current state of this condition. .. versionadded:: 3.0
src/anyio/_core/_synchronization.py:379
↓ 2 callersMethodstatistics
(self)
src/anyio/_backends/_trio.py:723
↓ 2 callersMethodstop
Signal the portal to shut down. This marks the portal as no longer accepting new calls and exits from :meth:`sleep_until_sto
src/anyio/from_thread.py:226
↓ 2 callersFunctionsucceed
()
tests/test_concurrency_utils.py:35
↓ 2 callersMethodterminate
(self)
src/anyio/_backends/_trio.py:392
↓ 2 callersFunctionwait_readable
Wait until the given object has data to be read. On Unix systems, ``obj`` must either be an integer file descriptor, or else an object w
src/anyio/_core/_sockets.py:733
↓ 2 callersMethodwait_readable
(cls, obj: FileDescriptorLike)
src/anyio/_backends/_trio.py:1363
↓ 2 callersFunctionwait_writable
Wait until the given object can be written to. :param obj: an object with a ``.fileno()`` method or an integer handle :raises ~anyio.Clo
src/anyio/_core/_sockets.py:766
↓ 2 callersMethodwait_writable
(cls, obj: FileDescriptorLike)
src/anyio/_backends/_trio.py:1372
↓ 2 callersMethodwalk
( self, top_down: bool = True, on_error: Callable[[OSError], object] | Non
src/anyio/_core/_fileio.py:976
↓ 2 callersMethodwith_name
(self, name: str)
src/anyio/_core/_fileio.py:997
↓ 2 callersMethodwith_stem
(self, stem: str)
src/anyio/_core/_fileio.py:1003
↓ 2 callersFunctionzip_longest
( *iterables: Iterable[object] | AsyncIterable[object], fillvalue: object = None, )
src/anyio/itertools.py:593
↓ 1 callersMethod__aenter__
(self)
src/anyio/from_thread.py:201
↓ 1 callersMethod__aenter__
(self)
src/anyio/_core/_tempfile.py:487
↓ 1 callersMethod__aenter__
(self)
src/anyio/_core/_synchronization.py:170
↓ 1 callersMethod__aenter__
(self)
src/anyio/_backends/_trio.py:226
↓ 1 callersMethod__aexit__
( self, exc_type: type[BaseException] | None, exc_val: BaseException | None, e
src/anyio/from_thread.py:205
↓ 1 callersMethod__aexit__
( self, exc_type: type[BaseException] | None, exc_val: BaseException | None, e
src/anyio/_core/_synchronization.py:173
↓ 1 callersMethod__aexit__
( self, exc_type: type[BaseException] | None, exc_val: BaseException | None, e
src/anyio/_backends/_trio.py:236
↓ 1 callersMethod__aexit__
( self, exc_type: object, exc_val: object, exc_tb: object )
tests/test_from_thread.py:344
↓ 1 callersMethod__aiter__
(self)
tests/test_itertools.py:54
↓ 1 callersMethod__anext__
(self)
src/anyio/itertools.py:124
↓ 1 callersMethod__asynccontextmanager__
Implement your async context manager logic here. This method **must** be decorated with :func:`@asynccontextmanager <context
src/anyio/_core/_contextmanagers.py:187
↓ 1 callersMethod__asynccontextmanager__
(self)
tests/test_contextmanagers.py:48
↓ 1 callersMethod__contextmanager__
Implement your context manager logic here. This method **must** be decorated with :func:`@contextmanager <contextlib.context
src/anyio/_core/_contextmanagers.py:95
↓ 1 callersMethod__contextmanager__
(self)
tests/test_contextmanagers.py:30
↓ 1 callersMethod__enter__
(self)
src/anyio/lowlevel.py:121
↓ 1 callersMethod__enter__
(self)
src/anyio/_core/_tasks.py:115
↓ 1 callersMethod__enter__
(self)
src/anyio/_backends/_trio.py:158
↓ 1 callersMethod__get__
( self, instance: object, owner: type | None = None )
src/anyio/functools.py:218
↓ 1 callersMethod__init__
( self: TemporaryFile[bytes], mode: OpenBinaryMode = ..., buffering: int = ...,
src/anyio/_core/_tempfile.py:49
↓ 1 callersMethod__init__
(self, lock: Lock | None = None)
src/anyio/_core/_synchronization.py:279
↓ 1 callersFunction_build_lazy_map
( module: ModuleType, )
src/anyio/_lazyimport.py:110
↓ 1 callersFunction_cancel_all_tasks
(loop: AbstractEventLoop)
src/anyio/_backends/_asyncio.py:258
↓ 1 callersFunction_is_type_checking_block
(test: ast.AST)
src/anyio/_lazyimport.py:155
↓ 1 callersMethod_reparent
Move this active scope from its current parent to ``new_parent``. Used by :meth:`TaskGroup.start` to move a task that has just calle
src/anyio/_backends/_asyncio.py:650
↓ 1 callersMethod_run_tests_and_fixtures
( self, receive_stream: MemoryObjectReceiveStream[ tuple[Awaitable[T_Retval], asyn
src/anyio/_backends/_asyncio.py:2386
↓ 1 callersFunction_shutdown_default_executor
Schedule the shutdown of the default executor.
src/anyio/_backends/_asyncio.py:280
↓ 1 callersFunction_shutdown_process_pool_on_exit
Shuts down worker processes belonging to this event loop. NOTE: this only works when the event loop was started using asyncio.run() or a
src/anyio/_backends/_asyncio.py:1286
↓ 1 callersFunction_task_started
Return ``True`` if the task has been started and has not finished.
src/anyio/_backends/_asyncio.py:351
↓ 1 callersMethodabsolute
(self)
src/anyio/_core/_fileio.py:466
↓ 1 callersMethodaccept
(self)
src/anyio/_backends/_asyncio.py:1650
↓ 1 callersMethodaccept
(self)
src/anyio/_backends/_trio.py:589
↓ 1 callersMethodaclose
Close the resource.
src/anyio/abc/_resources.py:38
↓ 1 callersMethodacquire
Decrement the semaphore value, blocking if necessary.
src/anyio/_core/_synchronization.py:438
↓ 1 callersMethodacquire
(self)
src/anyio/_backends/_asyncio.py:2187
↓ 1 callersMethodacquire
(self)
src/anyio/_backends/_trio.py:907
↓ 1 callersMethodacquire_nowait
Acquire the underlying lock, without blocking. :raises ~anyio.WouldBlock: if the operation would block
src/anyio/_core/_synchronization.py:304
↓ 1 callersMethodacquire_nowait
(self)
src/anyio/_backends/_trio.py:895
↓ 1 callersMethodacquire_on_behalf_of
Acquire a token, waiting if necessary for one to become available. :param borrower: the entity borrowing a token
src/anyio/_core/_synchronization.py:613
↓ 1 callersMethodacquire_on_behalf_of
(self, borrower: object)
src/anyio/_backends/_asyncio.py:2190
↓ 1 callersMethodacquire_on_behalf_of
(self, borrower: object)
src/anyio/_backends/_trio.py:910
↓ 1 callersMethodacquire_on_behalf_of_nowait
Acquire a token without waiting for one to become available. :param borrower: the entity borrowing a token :raises ~anyio.Wo
src/anyio/_core/_synchronization.py:595
↓ 1 callersFunctionagen_func
()
tests/test_debugging.py:136
↓ 1 callersFunctionasync_add
(x: int, y: int)
tests/test_eventloop.py:53
↓ 1 callersMethodcallback
(f: Future[T_Retval])
src/anyio/from_thread.py:251
↓ 1 callersMethodcancel_shielded_checkpoint
Allow the rescheduling of other tasks. This will give other tasks the opportunity to run, but without checking if the curren
src/anyio/abc/_eventloop.py:129
↓ 1 callersMethodcancelled_exception_class
(cls)
src/anyio/_backends/_trio.py:1103
↓ 1 callersMethodcheckpoint_if_cancelled
Check if the current task group has been cancelled. This will check if the task has been cancelled, but will not allow other tasks
src/anyio/abc/_eventloop.py:117
↓ 1 callersMethodchmod
(self, mode: int, *, follow_symlinks: bool = True)
src/anyio/_core/_fileio.py:569
↓ 1 callersMethodcleanup
(self)
src/anyio/_core/_tempfile.py:514
↓ 1 callersMethodcls_method
(cls, x: int)
tests/test_functools.py:321
↓ 1 callersMethodconnect
(self)
src/anyio/_core/_sockets.py:947
↓ 1 callersMethodconnect
(self)
src/anyio/streams/text.py:174
↓ 1 callersMethodconnect
(self)
src/anyio/streams/buffered.py:199
↓ 1 callersMethodconnect
(self)
src/anyio/streams/tls.py:425
↓ 1 callersMethodconnect_tcp
( cls, host: str, port: int, local_address: IPSockAddrType | None = None )
src/anyio/_backends/_trio.py:1253
↓ 1 callersMethodconnect_unix
(cls, path: str | bytes)
src/anyio/_backends/_trio.py:1271
↓ 1 callersMethodcopy_into
( self, target_dir: str | os.PathLike[str], *, follow_symlinks
src/anyio/_core/_fileio.py:522
↓ 1 callersFunctioncorofn
()
tests/test_taskgroups.py:1543
↓ 1 callersMethodcreate_cancel_scope
( cls, *, deadline: float = math.inf, shield: bool = False )
src/anyio/abc/_eventloop.py:151
↓ 1 callersMethodcreate_task
( self, coro: Coroutine[Any, Any, T_co], *, name: object = None, conte
src/anyio/_backends/_trio.py:263
↓ 1 callersMethodcreate_task_group
(cls)
src/anyio/_backends/_trio.py:1133
↓ 1 callersMethodcreate_tcp_listener
(cls, sock: socket.socket)
src/anyio/_backends/_trio.py:1282
↓ 1 callersMethodcreate_test_runner
(cls, options: dict[str, Any])
src/anyio/abc/_eventloop.py:427
↓ 1 callersMethodcreate_unix_listener
(cls, sock: socket.socket)
src/anyio/_backends/_trio.py:1286
↓ 1 callersFunctioncurrent_default_interpreter_limiter
Return the capacity limiter used by default to limit the number of concurrently running subinterpreters. Defaults to the number of CPU c
src/anyio/to_interpreter.py:231
↓ 1 callersFunctioncurrent_default_process_limiter
Return the capacity limiter that is used by default to limit the number of worker processes. :return: a capacity limiter object
src/anyio/to_process.py:191
↓ 1 callersMethodcurrent_default_thread_limiter
(cls)
src/anyio/_backends/_asyncio.py:3158
↓ 1 callersMethodcurrent_effective_deadline
Return the nearest deadline among all the cancel scopes effective for the current task. :return: - a clock value
src/anyio/abc/_eventloop.py:158
↓ 1 callersMethodcurrent_effective_deadline
(cls)
src/anyio/_backends/_trio.py:1129
↓ 1 callersMethodcurrent_token
Return an object that allows other threads to run code inside the event loop. :return: a token object, specific to the event loop ru
src/anyio/abc/_eventloop.py:84
↓ 1 callersMethodcurrent_token
(cls)
src/anyio/_backends/_trio.py:1095
↓ 1 callersFunctionemit_deprecation_warning
(module_name: str, name: str, target: str)
src/anyio/_lazyimport.py:81
↓ 1 callersFunctionensure_returns_coro
( func: Callable[P, Awaitable[T_Retval]], )
src/anyio/_backends/_trio.py:111
↓ 1 callersMethodexpanduser
(self)
src/anyio/_core/_fileio.py:594
↓ 1 callersMethodfeed_data
Append data directly into the buffer. Any data in the buffer will be consumed by receive operations before receiving anythin
src/anyio/streams/buffered.py:54
↓ 1 callersMethodfill
(self, link: _TeeLink[T])
src/anyio/itertools.py:91
↓ 1 callersFunctionfill_socket
(sock: socket.socket)
tests/test_sockets.py:214
↓ 1 callersMethodflush
(self)
src/anyio/_core/_fileio.py:170
↓ 1 callersFunctionfn
()
tests/test_taskgroups.py:1315
↓ 1 callersFunctionfoo
(_: Foo)
tests/test_to_thread.py:444
↓ 1 callersMethodfrom_uri
(cls, uri: str, *, limiter: CapacityLimiter | None = None)
src/anyio/_core/_fileio.py:480
↓ 1 callersMethodfull_match
( self, path_pattern: str, *, case_sensitive: bool | None = None )
src/anyio/_core/_fileio.py:483
↓ 1 callersFunctiongenerator_part
()
tests/test_debugging.py:124
↓ 1 callersFunctiongenfunc
(x: int, y: int)
tests/test_taskgroups.py:2531
↓ 1 callersMethodget_answer
(self)
tests/test_concurrency_utils.py:64
↓ 1 callersMethodget_current_task
(cls)
src/anyio/_backends/_trio.py:1441
← previousnext →301–400 of 2,270, ranked by callers