Skip to content

Commit ce8d490

Browse files
committed
🐛 fixed error event doesn't close connection
1 parent 19f815b commit ce8d490

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flask_queue_sse/__init__.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ def stream():
2929
msg = queue.get()
3030
yield msg
3131

32-
if search("event: end", msg):
32+
if search("event: end", msg) or search("event: error", msg):
3333
has_finished = True
3434

3535
return Response(stream(), mimetype="text/event-stream")
@@ -48,4 +48,4 @@ def send(self, payload: dict = None, event: str = "data"):
4848
except Full:
4949
del self.listeners[i]
5050

51-
return self
51+
return self

0 commit comments

Comments
 (0)