Skip to content

Commit 4279c8b

Browse files
committed
Fix bug in threadsafe_queue constructor.
1 parent 46438be commit 4279c8b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

v3/threadsafe/threadsafe_queue.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
class ThreadSafeQueue: # MicroPython optimised
1313
def __init__(self, buf):
1414
self._q = [0 for _ in range(buf)] if isinstance(buf, int) else buf
15-
self._size = len(buf)
15+
self._size = len(self._q)
1616
self._wi = 0
1717
self._ri = 0
1818
self._evput = asyncio.ThreadSafeFlag() # Triggered by put, tested by get

0 commit comments

Comments
 (0)