"""
def __init__(self, max_sleep=1):
super(TimedCallBackActor, self).__init__()
"""
def __init__(self, max_sleep=1):
super(TimedCallBackActor, self).__init__()
t, receiver, args, kwargs = heapq.heappop(self.messages)
try:
receiver(*args, **kwargs)
t, receiver, args, kwargs = heapq.heappop(self.messages)
try:
receiver(*args, **kwargs)