- r.get_response()
- (r, _, _) = select([self.rfh], [], [], 0)
- if not r: return event_added
+ (r, _, _) = select([self.rfh], [], [], timeout)
+ if r:
+ self.get_response(async = True)
+ timeout = 0
+ else:
+ break
+ if len(self.events) == 0: return (TICK, time())
+ ret = self.events[0]
+ del self.events[0]
+ return ret