Commit 1689bd93 authored by Denis Bilenko's avatar Denis Bilenko

queue: properly interpret maxsize parameter of Queue

parent 9f4ecfca
......@@ -12,7 +12,7 @@ class Queue(object):
if maxsize <= 0:
self.q = coros.Queue()
else:
self.q = coros.Channel(maxsize)
self.q = coros.Channel(maxsize-1)
def qsize(self):
"""Return the size of the queue."""
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment