From ee8d896d60e51a44ea700c9f18f8e845f873e62f Mon Sep 17 00:00:00 2001
From: Jakob Ketterl <jakob.ketterl@gmx.de>
Date: Sun, 17 Jan 2021 21:01:54 +0100
Subject: [PATCH] implement output buffer shutdown

---
 csdr/chain/__init__.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/csdr/chain/__init__.py b/csdr/chain/__init__.py
index 4a7729a..33ec232 100644
--- a/csdr/chain/__init__.py
+++ b/csdr/chain/__init__.py
@@ -19,6 +19,8 @@ class Chain(Flow):
         w2.setInput(buffer)
 
     def stop(self):
+        if self.output is not None:
+            self.output.stop()
         for w in self.workers:
             w.stop()