super(TimedCallBackActor, self).__init__()
self._proxy = self.actor_ref.tell_proxy()
self.messages = []
self.max_sleep = max_sleep
super(TimedCallBackActor, self).__init__()
self._proxy = self.actor_ref.tell_proxy()
self.messages = []
self.max_sleep = max_sleep
def schedule(self, delivery_time, receiver, *args, **kwargs):
if not self.messages:
def schedule(self, delivery_time, receiver, *args, **kwargs):
if not self.messages:
t, receiver, args, kwargs = heapq.heappop(self.messages)
try:
receiver(*args, **kwargs)
t, receiver, args, kwargs = heapq.heappop(self.messages)
try:
receiver(*args, **kwargs)