2024-06-18 02:23:19 +02:00
|
|
|
from typing import Any, Awaitable
|
2022-12-04 03:03:38 +01:00
|
|
|
from typing import Callable
|
|
|
|
from typing import Optional
|
2024-06-18 02:23:19 +02:00
|
|
|
from typing import TypeVar, TypeAlias
|
2022-12-04 03:03:38 +01:00
|
|
|
|
2024-06-18 02:23:19 +02:00
|
|
|
Handler: TypeAlias = Callable[[str], Awaitable[Any]]
|
|
|
|
DictHandler: TypeAlias = Callable[[str, dict[str, Any]], Awaitable[Any]]
|
|
|
|
ClientHandler = TypeVar("ClientHandler", bound=Callable[[dict[str, Any]], Any] | Callable[[], Any])
|
2022-11-27 16:22:07 +01:00
|
|
|
|
|
|
|
class _session_context_manager:
|
|
|
|
async def __aenter__(self) -> dict[str, Any]: ...
|
|
|
|
async def __aexit__(self, *args: list[Any]) -> None: ...
|
|
|
|
|
|
|
|
class AsyncServer:
|
|
|
|
def __init__(
|
2023-11-01 13:01:34 +01:00
|
|
|
self,
|
|
|
|
cors_allowed_origins: str,
|
|
|
|
logger: bool,
|
|
|
|
engineio_logger: bool,
|
|
|
|
json: Any,
|
2022-11-27 16:22:07 +01:00
|
|
|
): ...
|
|
|
|
async def emit(
|
|
|
|
self,
|
|
|
|
message: str,
|
2022-12-04 03:03:38 +01:00
|
|
|
body: Any = None,
|
2022-11-27 16:22:07 +01:00
|
|
|
room: Optional[str] = None,
|
|
|
|
) -> None: ...
|
|
|
|
def session(self, sid: str) -> _session_context_manager: ...
|
2024-10-14 13:02:12 +02:00
|
|
|
def on(
|
|
|
|
self, event: str, handler: Optional[Handler | DictHandler] = None
|
|
|
|
) -> Callable[[Handler | DictHandler], Handler | DictHandler]: ...
|
2023-11-01 13:01:34 +01:00
|
|
|
async def enter_room(self, sid: str, room: str) -> None: ...
|
|
|
|
async def leave_room(self, sid: str, room: str) -> None: ...
|
2022-11-27 16:22:07 +01:00
|
|
|
def attach(self, app: Any) -> None: ...
|
2023-01-25 15:47:04 +00:00
|
|
|
async def disconnect(self, sid: str) -> None: ...
|
2025-01-01 13:05:13 +01:00
|
|
|
def instrument(self, auth: dict[str, str]) -> None: ...
|
2022-11-27 16:22:07 +01:00
|
|
|
|
|
|
|
class AsyncClient:
|
2022-12-04 03:03:38 +01:00
|
|
|
def __init__(self, json: Any = None): ...
|
2024-10-09 16:17:55 +02:00
|
|
|
def on(
|
|
|
|
self, event: str, handler: Optional[Callable[..., Any]] = None
|
|
|
|
) -> Callable[[ClientHandler], ClientHandler]: ...
|
2022-11-27 16:22:07 +01:00
|
|
|
async def wait(self) -> None: ...
|
|
|
|
async def connect(self, server: str) -> None: ...
|
|
|
|
async def disconnect(self) -> None: ...
|
2022-12-04 03:03:38 +01:00
|
|
|
async def emit(self, message: str, data: Any = None) -> None: ...
|