Commit 16611d19 authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Add function for likely_done case

parent 75bb02c6
Pipeline #331 failed with stage
in 1 minute and 47 seconds
......@@ -168,6 +168,7 @@ class Streamer:
return
if (has_data or new_substream is not None) and self.end_of_stream_callback:
self.worker.handle_likely_done()
# call the callback only once
self.end_of_stream_callback(new_substream)
self.end_of_stream_callback = None
......
......@@ -29,6 +29,12 @@ class Worker:
def handle_receiver_critical_error(self):
self.handle_receiver_error()
def handle_likely_done(self):
"""
Call when substream is likely done and new substream is created
"""
pass
def pre_scan(self, data, metadata):
"""
If metadata stream is given this function is called at the beginning of
......
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