- def next_event(self):
- if len(self.events) > 0:
- ret = self.events[0]
- del self.events[0]
- return ret
- return None
-
- def wait_for_events(self, timeout = None):
- if self.events: return True
- (r, _, _) = select([self.rfh], [], [], timeout)
- if not r: return False
- event_added = False
+ def next_event(self, timeout = None):
+ # we don't want to buffer in the serial port, so we get all the events
+ # we can ASAP.
+ if len(self.events) > 0: timeout = 0