Don't re-use event objects, there might be a bug
This commit is contained in:
@@ -260,7 +260,7 @@ class CoroutinePool(pools.Pool):
|
|||||||
""" Private, infinite loop run by a pooled coroutine. """
|
""" Private, infinite loop run by a pooled coroutine. """
|
||||||
while True:
|
while True:
|
||||||
recvd = sender.wait()
|
recvd = sender.wait()
|
||||||
sender.reset()
|
sender = event()
|
||||||
(evt, func, args, kw) = recvd
|
(evt, func, args, kw) = recvd
|
||||||
self._safe_apply(evt, func, args, kw)
|
self._safe_apply(evt, func, args, kw)
|
||||||
api.get_hub().cancel_timers(api.getcurrent())
|
api.get_hub().cancel_timers(api.getcurrent())
|
||||||
|
Reference in New Issue
Block a user