Rusticus
/
Simple-SSE-Server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Uncomment message id, remove debug prints

This commit is contained in:
Markus Bauer 2021-05-18 16:34:15 +02:00
parent e3c61e2afe
commit 235cf713a3
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/SimpleSseSever.py
View File

@ -125,14 +125,10 @@ class SseStream():
print( "Stream object is deleted") print( "Stream object is deleted")
def __iter__(self): def __iter__(self):
print("Iter called")
print(f'Queue Size: {self._queue.qsize()}')
while True: while True:
msg = self._queue.get(block=True, timeout=None) msg = self._queue.get(block=True, timeout=None)
if isinstance( msg, Sse ): if isinstance( msg, Sse ):
print("Message: ", msg)
for data in msg: for data in msg:
print(data)
yield data.encode('utf-8') yield data.encode('utf-8')
def addMessage(self, event_name, data, id = 0): def addMessage(self, event_name, data, id = 0):
@ -148,10 +144,10 @@ class SseStream():
id: int id: int
id of the event, if set to 0 no ID will be sent """ id of the event, if set to 0 no ID will be sent """
event = Sse() event = Sse()
# if id > 0: if id > 0:
# event.set_event_id(id) event.set_event_id(id)
# else: else:
# event.reset_event_id() event.reset_event_id()
event.add_message( event_name, data ) event.add_message( event_name, data )
self._queue.put( event ) self._queue.put( event )