def patch_sse():
    from cyclone import escape
    import cyclone.sse
    def new_sendEvent(self, message, event=None, eid=None, retry=None):
        if isinstance(message, dict):
            message = escape.json_encode(message)
        if isinstance(message, str):
            message = message.encode("utf-8")
        assert isinstance(message, bytes)
        if eid:
            self.transport.write(b"id: " + eid.encode("utf-8") + b"\n")
        if event:
            self.transport.write(b"event: " + event + b"\n")
        if retry:
            self.transport.write(b"retry: " + retry.encode("utf-8") + b"\n")
        self.transport.write(b"data: " + message + b"\n\n")

    cyclone.sse.SSEHandler.sendEvent = new_sendEvent