Functions — github.com/agronholm/anyio

CodeHub MCPcopy Create free account

hub / github.com/agronholm/anyio / functions

Functions2,163 in github.com/agronholm/anyio

⨍ Functions 2,163◇ Types & classes 270↳ Endpoints 11

(self, max_bytes: int)

src/anyio/_core/_exceptions.py:100

src/anyio/_core/_exceptions.py:153

src/anyio/_core/_asyncio_selector_thread.py:18

src/anyio/_core/_synchronization.py:120

(self, *, fast_acquire: bool = False)

src/anyio/_core/_synchronization.py:211

( self, initial_value: int, *, max_value: int | None = None, fast_acqu

src/anyio/_core/_synchronization.py:399

( self, initial_value: int, *, max_value: int | None = None, fast_acqu

src/anyio/_core/_synchronization.py:480

(self, total_tokens: float)

src/anyio/_core/_synchronization.py:652

(self, action: str = "using")

src/anyio/_core/_synchronization.py:756

(self, coro: Coroutine[Any, Any, T_co], name: object)

src/anyio/_core/_tasks.py:255

( self, id: int, parent_id: int | None, name: str | None, coro: Genera

src/anyio/_core/_testing.py:22

:param connectable: the bytestream endpoint to wrap

src/anyio/streams/text.py:166

:param stream: the stream to be wrapped

src/anyio/streams/buffered.py:163

:param connectable: the connectable to wrap

src/anyio/streams/buffered.py:191

( self, connectable: AnyByteStreamConnectable, *, hostname: str | None = None,

src/anyio/streams/tls.py:404

(self, file: IO[bytes])

src/anyio/streams/file.py:36

( self, *, debug: bool | None = None, loop_factory: Callable[[

src/anyio/_backends/_asyncio.py:132

(self, deadline: float = math.inf, shield: bool = False)

src/anyio/_backends/_asyncio.py:404

(self, parent_id: int | None, cancel_scope: CancelScope | None)

src/anyio/_backends/_asyncio.py:714

(self, future: asyncio.Future, parent_id: int)

src/anyio/_backends/_asyncio.py:728

src/anyio/_backends/_asyncio.py:752

( self, root_task: asyncio.Task, workers: set[WorkerThread], idle_workers: deq

src/anyio/_backends/_asyncio.py:984

(self, transport: asyncio.Transport, protocol: StreamProtocol)

src/anyio/_backends/_asyncio.py:1315

(self, raw_socket: socket.socket)

src/anyio/_backends/_asyncio.py:1407

(self, raw_socket: socket.socket)

src/anyio/_backends/_asyncio.py:1571

(self, raw_socket: socket.socket)

src/anyio/_backends/_asyncio.py:1628

( self, transport: asyncio.DatagramTransport, protocol: DatagramProtocol )

src/anyio/_backends/_asyncio.py:1665

( self, transport: asyncio.DatagramTransport, protocol: DatagramProtocol )

src/anyio/_backends/_asyncio.py:1715

src/anyio/_backends/_asyncio.py:1853

( self, initial_value: int, *, max_value: int | None = None, fast_acqu

src/anyio/_backends/_asyncio.py:1968

(self, total_tokens: float)

src/anyio/_backends/_asyncio.py:2050

(self, signals: tuple[Signals, ...])

src/anyio/_backends/_asyncio.py:2175

(self, task: asyncio.Task)

src/anyio/_backends/_asyncio.py:2221

( self, *, debug: bool | None = None, use_uvloop: bool = False, loop_f

src/anyio/_backends/_asyncio.py:2256

src/anyio/_backends/_asyncio.py:2438

(self, original: trio.CancelScope | None = None, **kwargs: Any)

src/anyio/_backends/_trio.py:151

src/anyio/_backends/_trio.py:216

(self, trio_socket: TrioSocketType)

src/anyio/_backends/_trio.py:446

(self, trio_socket: TrioSocketType)

src/anyio/_backends/_trio.py:477

(self, raw_socket: socket.socket)

src/anyio/_backends/_trio.py:580

(self, raw_socket: socket.socket)

src/anyio/_backends/_trio.py:596

(self, trio_socket: TrioSocketType)

src/anyio/_backends/_trio.py:611

(self, trio_socket: TrioSocketType)

src/anyio/_backends/_trio.py:633

(self, trio_socket: TrioSocketType)

src/anyio/_backends/_trio.py:654

(self, trio_socket: TrioSocketType)

src/anyio/_backends/_trio.py:678

src/anyio/_backends/_trio.py:709

( self, initial_value: int, *, max_value: int | None = None, fast_acqu

src/anyio/_backends/_trio.py:796

( self, total_tokens: float | None = None, *, original: trio.CapacityLimiter |

src/anyio/_backends/_trio.py:851

(self, signals: tuple[Signals, ...])

src/anyio/_backends/_trio.py:935

(self, **options: Any)

src/anyio/_backends/_trio.py:965

(self, task: trio.lowlevel.Task)

src/anyio/_backends/_trio.py:1060

(self, ignore_error: bool)

tests/test_from_thread.py:338

(self, *args: P.args, **kwargs: P.kwargs)

tests/conftest.py:202

(self, handle_exc: bool = False)

tests/test_contextmanagers.py:42

(self, handle_exc: bool = False)

tests/test_contextmanagers.py:124

(self, handle_exc: bool = False)

tests/test_contextmanagers.py:228

(self, iterable: Iterable[T])

tests/test_itertools.py:51

Method__init_subclass__

src/anyio/_core/_typedattr.py:25

(self, other: pathlib.PurePath | Path)

src/anyio/_core/_fileio.py:403

(self, other: pathlib.PurePath | Path)

src/anyio/_core/_fileio.py:399

src/anyio/_core/_synchronization.py:85

src/anyio/_core/_synchronization.py:117

(cls, *, fast_acquire: bool = False)

src/anyio/_core/_synchronization.py:208

( cls, initial_value: int, *, max_value: int | None = None, fast_acqui

src/anyio/_core/_synchronization.py:385

( cls, initial_value: int, *, max_value: int | None = None, fast_acqui

src/anyio/_core/_synchronization.py:471

(cls, total_tokens: float)

src/anyio/_core/_synchronization.py:531

(cls, total_tokens: float)

src/anyio/_core/_synchronization.py:649

( cls, *, deadline: float = math.inf, shield: bool = False )

src/anyio/_core/_tasks.py:57

( # type: ignore[misc] cls, max_buffer_size: float = 0, item_type: object = None )

src/anyio/_core/_streams.py:36

( cls, *, deadline: float = math.inf, shield: bool = False )

src/anyio/_backends/_asyncio.py:399

src/anyio/_backends/_asyncio.py:1850

( cls, initial_value: int, *, max_value: int | None = None, fast_acqui

src/anyio/_backends/_asyncio.py:1959

(cls, total_tokens: float)

src/anyio/_backends/_asyncio.py:2047

( cls, original: trio.CancelScope | None = None, **kwargs: object )

src/anyio/_backends/_trio.py:146

src/anyio/_backends/_trio.py:706

( cls, initial_value: int, *, max_value: int | None = None, fast_acqui

src/anyio/_backends/_trio.py:787

( cls, total_tokens: float | None = None, *, original: trio.CapacityLimiter |

src/anyio/_backends/_trio.py:843

Method__post_init__

src/anyio/_core/_sockets.py:922

Method__post_init__

src/anyio/streams/stapled.py:120

Method__post_init__

(self, encoding: str, errors: str)

src/anyio/streams/text.py:56

Method__post_init__

(self, encoding: str)

src/anyio/streams/text.py:96

Method__post_init__

(self, encoding: str, errors: str)

src/anyio/streams/text.py:136

Method__post_init__

src/anyio/streams/memory.py:84

Method__post_init__

src/anyio/streams/memory.py:203

Method__post_init__

(self, data: bytes)

tests/streams/test_stapled.py:26

Method__post_init__

(self, data: Iterable[T_Item])

tests/streams/test_stapled.py:115

src/anyio/lowlevel.py:227

src/anyio/_core/_fileio.py:386

src/anyio/_core/_tasks.py:408

src/anyio/_core/_testing.py:45

src/anyio/streams/memory.py:48

Method__rtruediv__

(self, other: str | PathLike[str])

src/anyio/_core/_fileio.py:418

src/anyio/_core/_fileio.py:383

src/anyio/_core/_exceptions.py:44

Method__truediv__

(self, other: str | PathLike[str])

src/anyio/_core/_fileio.py:415

Method__vfspath__

src/anyio/_core/_fileio.py:380

Method_call_func

( self, func: Callable[[Unpack[PosArgsT]], Awaitable[T_Retval] | T_Retval], args: tupl

src/anyio/from_thread.py:240

Method_check_closed

src/anyio/_backends/_trio.py:450

Function_check_main_importable

Helper that runs in the worker process to check main was imported correctly

tests/test_to_process.py:157

Method_current_vars

src/anyio/lowlevel.py:152

← previous next →601–700 of 2,163, ranked by callers