@@ -30,7 +30,7 @@ class Subscriber:
|
|||||||
try:
|
try:
|
||||||
async with timeout(tout):
|
async with timeout(tout):
|
||||||
log.debug('Subscriber %s is waiting for an event', id(self))
|
log.debug('Subscriber %s is waiting for an event', id(self))
|
||||||
await future
|
return await future
|
||||||
except TimeoutError:
|
except TimeoutError:
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user