blob: 0c140187fc097b575d2c71d039984631314ad2ef (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
import Queue
from threading import Timer
class Processor(object):
def __init__(self, input_queue):
self.input_queue = input_queue
self.listeners = []
def again(self, t):
next_run = Timer(t, self.do)
next_run.start()
def do(self):
"""
The do method should:
Consider input in the input queue
call self.again(timeDelay)
call self.done(data)
In that order
"""
raise NotImplementedError("proc must be defined")
def done(self, data):
[l.handle(data) for l in self.listeners]
#todo [rcoh] - there should be a better way to do this.
class Listener(object):
def handle(self, data):
raise NotImplementedError("handle must be defined")
|
