flask_sse_kafka.py 文件源码

def stream(self):
        """
        A view function that streams server-sent events. Ignores any
        :mailheader:`Last-Event-ID` headers in the HTTP request.
        """
        current_app.logger.debug('in ServerSentEventsBlueprint.stream')

        @stream_with_context
        def generator():
            for message in self.messages():
                lines = ["data:{value}".format(value=line) for line in
                         message.splitlines()]
                lines.insert(0, "event:{value}".format(value='message'))
                yield "\n".join(lines) + "\n\n"

        return current_app.response_class(
            generator(),
            mimetype='text/event-stream',
        )