#!/usr/bin/env python
# -*- coding: utf-8 -*-
import asyncio
from datetime import datetime, timedelta

from aiohttp_sse_client import client as sse_client

from .const import WPT_SERVER


async def test_eventsource_request_cancellation():
    """Test EventSource: reconnection event.
    
    ..seealso: https://github.com/web-platform-tests/wpt/blob/master/
    eventsource/eventsource-request-cancellation.htm
    """
    closed = False
    def on_open():
        if closed:
            assert False

    def on_error():
        assert source.ready_state == sse_client.READY_STATE_CLOSED

    try:
        async with sse_client.EventSource(
            WPT_SERVER + 'resources/message.py?sleep=1000&message=' +
            "retry:1000\ndata:abc\n\n",
            on_open=on_open,
            on_error=on_error
        ) as source:
            raise ConnectionAbortedError
    except ConnectionAbortedError:
        closed = True
        await asyncio.sleep(1)
        assert source.ready_state == sse_client.READY_STATE_CLOSED
        pass

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import asyncio
from datetime import datetime, timedelta

from aiohttp_sse_client import client as sse_client

from .const import WPT_SERVER


async def test_eventsource_request_cancellation():
    """Test EventSource: reconnection event.
    
    ..seealso: https://github.com/web-platform-tests/wpt/blob/master/
    eventsource/eventsource-request-cancellation.htm
    """
    closed = False
    def on_open():
        if closed:
            assert False

    def on_error():
        assert source.ready_state == sse_client.READY_STATE_CLOSED

    try:
        async with sse_client.EventSource(
            WPT_SERVER + 'resources/message.py?sleep=1000&message=' +
            "retry:1000\ndata:abc\n\n",
            on_open=on_open,
            on_error=on_error
        ) as source:
            raise ConnectionAbortedError
    except ConnectionAbortedError:
        closed = True
        await asyncio.sleep(1)
        assert source.ready_state == sse_client.READY_STATE_CLOSED
        pass

#!/usr/bin/env python # -*- coding: utf-8 -*- Test EventSource: reconnection event.          ..seealso: https://github.com/web-platform-tests/wpt/blob/master/     eventsource/eventsource-request-cancellation.htm