"""This module contains type hints for the anyio library. It was auto-generated so may include errors."""

from collections.abc import Callable, Coroutine
from types import TracebackType
from typing import Any, Optional, TypeVar, Union, overload

T = TypeVar("T")
T_Retval = TypeVar("T_Retval")

class CapacityLimiter:
    def __init__(self, total_tokens: float): ...
    async def acquire(self) -> None: ...
    async def acquire_nowait(self) -> None: ...
    def release(self) -> None: ...
    @property
    def total_tokens(self) -> float: ...
    @property
    def available_tokens(self) -> float: ...
    def __enter__(self) -> CapacityLimiter: ...
    def __exit__(
        self,
        exc_type: Optional[type],
        exc_val: Optional[BaseException],
        exc_tb: Optional[TracebackType],
    ) -> None: ...

class to_thread:
    @staticmethod
    def run_sync(
        func: Callable[..., T],
        *args: Any,
        cancellable: bool = False,
        limiter: Optional[CapacityLimiter] = None,
        **kwargs: Any,
    ) -> Coroutine[Any, Any, T]: ...

@overload
def run(
    func: Callable[[], T_Retval],
    *,
    backend: Optional[str] = ...,
    backend_options: Optional[dict] = ...,
) -> T_Retval: ...
@overload
def run(
    func: Callable[..., T_Retval],
    *args: Any,
    backend: Optional[str] = ...,
    backend_options: Optional[dict] = ...,
    **kwargs: Any,
) -> T_Retval: ...
def sleep(delay: Union[int, float]) -> Coroutine[Any, Any, None]: ...
async def sleep_forever() -> None: ...
def current_time() -> float: ...
def get_cancelled_exc_class() -> type[BaseException]: ...
def create_task_group() -> TaskGroup: ...

class TaskGroup:
    async def __aenter__(self) -> TaskGroup: ...
    async def __aexit__(
        self,
        exc_type: Optional[type],
        exc_val: Optional[BaseException],
        exc_tb: Optional[TracebackType],
    ) -> bool: ...
    def start_soon(
        self,
        func: Callable[..., Coroutine[Any, Any, Any]],
        *args: Any,
        name: Optional[str] = None,
        **kwargs: Any,
    ) -> None: ...

def create_memory_object_stream(
    max_buffer_size: int = 0,
) -> tuple[MemoryObjectSender, MemoryObjectReceiver]: ...

class MemoryObjectSender:
    async def send(self, item: Any) -> None: ...
    def send_nowait(self, item: Any) -> None: ...

class MemoryObjectReceiver:
    async def receive(self) -> Any: ...
    def receive_nowait(self) -> Any: ...