Add-on: document timeout parameter of PackThread.poll()
The timeout should be specified in seconds, which wasn't documented before. No functional changes.
This commit is contained in:
parent
c41eda4a09
commit
152adcb777
@ -180,9 +180,9 @@ class PackThread(threading.Thread):
|
|||||||
def poll(self, timeout: Optional[int] = None) -> Optional[Message]:
|
def poll(self, timeout: Optional[int] = None) -> Optional[Message]:
|
||||||
"""Poll the queue, return the first message or None if there is none.
|
"""Poll the queue, return the first message or None if there is none.
|
||||||
|
|
||||||
:param timeout: Max time to wait for a message to appear on the queue.
|
:param timeout: Max time to wait for a message to appear on the queue,
|
||||||
If None, will not wait and just return None immediately (if there is
|
in seconds. If None, will not wait and just return None immediately
|
||||||
no queued message).
|
(if there is no queued message).
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
return self.queue.get(block=timeout is not None, timeout=timeout)
|
return self.queue.get(block=timeout is not None, timeout=timeout)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user