Add missing break statement

Author: rhpvorderman

src/isal/igzip_threaded.py

@@ -46,6 +46,7 @@ def _decompress(self):
             while self.running:
                 try:
                     block_queue.put(data, timeout=0.05)
+                    break
                 except queue.Full:
                     pass
 

tests/tests_igzip_threaded.py

@@ -0,0 +1,21 @@
+# Copyright (c) 2001, 2002, 2003, 2004, 2005, 2006, 2007, 2008, 2009, 2010,
+# 2011, 2012, 2013, 2014, 2015, 2016, 2017, 2018, 2019, 2020, 2021, 2022
+# Python Software Foundation; All Rights Reserved
+
+# This file is part of python-isal which is distributed under the
+# PYTHON SOFTWARE FOUNDATION LICENSE VERSION 2.
+
+import gzip
+from pathlib import Path
+
+from isal import igzip_threaded
+
+TEST_FILE = str((Path(__file__).parent / "data" / "test.fastq.gz"))
+
+
+def test_threaded_read():
+    with igzip_threaded.open(TEST_FILE, "rb") as thread_f:
+        thread_data = thread_f.read()
+    with gzip.open(TEST_FILE, "rb") as f:
+        data = f.read()
+    assert thread_data == data