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));