Stream

ITD_SSE_PING

ITD_SSE_PING = 15

connect_notifications

connect_notifications(
    client: AsyncClient,
    access_token: str,
    domain: str = "xn--d1ah4a.com",
    **kwargs,
) -> AsyncGenerator[
    AsyncIterator[
        ConnectedEvent | NotificationEvent | SSEEvent
    ],
    None,
]

Подключиться к SEE стриму уведомлений.

PARAMETER	DESCRIPTION
client	httpx.AsyncClient TYPE: AsyncClient
access_token	access токен TYPE: str
domain	домен TYPE: str DEFAULT: 'xn--d1ah4a.com'

RAISES	DESCRIPTION
SSEError	ошибка SSE

Examples:

async with connect_notifications(client, access_token) as events:
    async for event in events:
        if isinstance(event, NotificationEvent):
            print(event)