Merge branch 'feature_stream_no_sink_size' into develop

Author: shtaxxx

veriloggen/thread/stream.py

@@ -77,6 +77,8 @@ def __init__(self, m, name, clk, rst,
         self.start = self.module.Reg(
             '_'.join(['', self.name, 'start']), initval=0)
 
+        self.end_flag = self.module.Reg(
+            '_'.join(['', self.name, 'end_flag']), initval=0)
         self.term_sink = self.module.Reg(
             '_'.join(['', self.name, 'term_sink']), initval=0)
 
@@ -1072,6 +1074,13 @@ def run(self, fsm):
             self.sink_wait_count.inc()
         )
 
+        self.fsm.seq(
+            self.end_flag(0)
+        )
+        self.fsm.seq.If(self.seq.Prev(end_cond, num_wdelay))(
+            self.end_flag(1)
+        )
+
         pipeline_depth = self.pipeline_depth()
 
         self.fsm.seq(