Я хочу реализовать потоковую передачу sse для нескольких клиентов и наткнулся на множество фрагментов кода, похожих на следующий.
@route("/stream")
def stream():
def event_stream():
while True:
if message_to_send:
yield "data:
{}\n\n".format(message_to_send)
return Response(event_stream(), mimetype="text/event-stream")
В моем случае это не работает из-за блокирующего вызова event_stream. Мой вопрос заключается в том, как асинхронно обрабатывать это в рамках flask (без gunicorn, redis, ...).