From aec8dbc33aa050d826ab440477b46f596cb9e820 Mon Sep 17 00:00:00 2001
From: Doug Hoyte <doug@hcsw.org>
Date: Wed, 16 Aug 2023 13:31:25 -0400
Subject: [PATCH] WriterPipeline clean shutdown

---
 src/WriterPipeline.h | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/WriterPipeline.h b/src/WriterPipeline.h
index d01fa7a..cc293e2 100644
--- a/src/WriterPipeline.h
+++ b/src/WriterPipeline.h
@@ -151,6 +151,12 @@ struct WriterPipeline {
         });
     }
 
+    ~WriterPipeline() {
+        flush();
+        validatorThread.join();
+        writerThread.join();
+    }
+
     void write(WriterPipelineInput &&inp) {
         numLive++;
         validatorInbox.push_move(std::move(inp));