diff --git a/hexlib/concurrency.py b/hexlib/concurrency.py
index 34d3219..864703a 100644
--- a/hexlib/concurrency.py
+++ b/hexlib/concurrency.py
@@ -12,7 +12,7 @@ class StatefulStreamWorker:
         pass
 
     def run(self, q: Queue):
-        for chunk in queue_iter(q, timeout=3):
+        for chunk in queue_iter(q, joinable=False, timeout=3):
             self.process_chunk(chunk)
 
     def process_chunk(self, chunk):
diff --git a/setup.py b/setup.py
index 56d3d27..40855f4 100644
--- a/setup.py
+++ b/setup.py
@@ -2,7 +2,7 @@ from setuptools import setup
 
 setup(
     name="hexlib",
-    version="1.53",
+    version="1.54",
     description="Misc utility methods",
     author="simon987",
     author_email="me@simon987.net",