+
+class PerServiceBase(object):
+ EventMap = { }
+
+ @staticmethod
+ def event(ev):
+ func_list = PerServiceBase.EventMap.setdefault(ev, [])
+ for func in func_list:
+ if func[0]: # with_event
+ func[1](ev)
+ else:
+ func[1]()
+
+ def __init__(self, navcore, eventmap, with_event=False):
+ self.navcore = navcore
+ self.eventmap = eventmap
+ self.poll_timer = eTimer()
+ self.with_event = with_event
+
+ self.poll_timer.callback.append(self.poll)
+
+ EventMap = PerServiceBase.EventMap
+ if not len(EventMap):
+ self.navcore.event.append(PerServiceBase.event)
+
+ EventMap = EventMap.setdefault
+ for x in eventmap.iteritems():
+ EventMap(x[0], []).append((with_event, x[1]))
+
+ # start with stopped state, so simulate that
+ evEndEntry = eventmap.get(iPlayableService.evEnd)
+ if evEndEntry:
+ if with_event:
+ evEndEntry(iPlayableService.evEnd)
+ else:
+ evEndEntry()
+
+ def destroy(self):
+ EventMap = PerServiceBase.EventMap.setdefault
+ for x in self.eventmap.iteritems():
+ EventMap(x[0], []).remove((self.with_event, x[1]))
+
+ def enablePolling(self, interval=60000):
+ if interval:
+ self.poll_timer.start(interval)
+ else:
+ self.poll_timer.stop()