simon987/hexlib
1
0
Fork 0
mirror of https://github.com/simon987/hexlib.git synced 2025-04-10 14:06:43 +00:00
Code Issues Projects Releases Wiki Activity

queue_iter fix

Browse Source
This commit is contained in:
simon987 2021-09-19 12:44:49 -04:00
parent 71cd00c063
commit f4a5e6cf53
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hexlib/concurrency.py
View File

@ -12,7 +12,7 @@ class StatefulStreamWorker:
pass pass
def run(self, q: Queue): 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) self.process_chunk(chunk)
def process_chunk(self, chunk): def process_chunk(self, chunk):

2
setup.py
View File

@ -2,7 +2,7 @@ from setuptools import setup
setup( setup(
name="hexlib", name="hexlib",
version="1.53", version="1.54",
description="Misc utility methods", description="Misc utility methods",
author="simon987", author="simon987",
author_email="me@simon987.net", author_email="me@simon987.net",