Skip to content

Commit bf0f717

Browse files
committed
Make sure close method of raw files is tested
1 parent 5eddafc commit bf0f717

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

src/isal/igzip_threaded.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ def __init__(self, fp, queue_size=4, block_size=8 * 1024 * 1024):
8888
self.running = True
8989
self.worker.start()
9090

91-
def _check_closed(self, msg = None):
91+
def _check_closed(self, msg=None):
9292
if self._closed:
9393
raise ValueError("I/O operation on closed file")
9494

@@ -212,7 +212,7 @@ def __init__(self,
212212
self._write_gzip_header()
213213
self.start()
214214

215-
def _check_closed(self, msg = None):
215+
def _check_closed(self, msg=None):
216216
if self._closed:
217217
raise ValueError("I/O operation on closed file")
218218

tests/test_igzip_threaded.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,16 +84,16 @@ def test_threaded_write_error(monkeypatch):
8484

8585

8686
def test_close_reader():
87-
f = igzip_threaded.open(TEST_FILE, "rb")
87+
tmp = io.BytesIO(Path(TEST_FILE).read_bytes())
88+
f = igzip_threaded._ThreadedGzipReader(tmp, "rb")
8889
f.close()
8990
assert f.closed
9091
# Make sure double closing does not raise errors
9192
f.close()
9293

9394

9495
def test_close_writer():
95-
raw = tempfile.TemporaryFile()
96-
f = igzip_threaded.open(raw, "wb")
96+
f = igzip_threaded._ThreadedGzipWriter(io.BytesIO(), "wb")
9797
f.close()
9898
assert f.closed
9999
# Make sure double closing does not raise errors

0 commit comments

Comments
 (0)