SSE

Simple asyncio/aiohttp wrapper for Server-Sent Events.

Usage

Sending events:

import asyncio
import sse


class Handler(sse.Handler):
    @asyncio.coroutine
    def handle_request(self):
        yield from asyncio.sleep(2)
        self.send('foo')
        yield from asyncio.sleep(2)
        self.send('bar', event='wakeup')

start_server = sse.serve(Handler, 'localhost', 8888)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

Validating incoming requests:

class Handler(sse.Handler):
    def validate_sse(self):
        super().validate_sse()
        # use self.request / self.payload
        if not self.request.path.startswith('/live'):
            raise sse.SseException()

Sending JSON data:

class Handler(sse.Handler):
    @asyncio.coroutine
    def handle_request(self):
        self.send({'foo': 'bar'})

Sending IDs / event names / retry information:

class Handler(sse.Handler):
    @asyncio.coroutine
    def handle_request(self):
        self.send('some data', id=12345, event='something', retry=10000)