Commit e9bae96d authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Send stream finish flag only once

parent a604da6e
......@@ -170,10 +170,11 @@ class Streamer:
return None, None
except StreamFinishedError as err:
log.info("Stream is finished")
self.stream_finished = True
self._handle_end_of_stream()
stream_info = self.receiver.get_stream_info()
self.worker.stream_finished(stream_info)
if not self.stream_finished:
stream_info = self.receiver.get_stream_info()
self.worker.stream_finished(stream_info)
self.stream_finished = True
left_msgs = len(self.receiver.get_unacknowledged_messages())
log.info("Number of unacknowledged messages = %s", left_msgs)
if left_msgs == 0 or self.receiver.n_resend_nacs == 0:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment