(self, url, count)
| 26 | |
| 27 | class Recv(MessagingHandler): |
| 28 | def __init__(self, url, count): |
| 29 | super(Recv, self).__init__(auto_accept=False) |
| 30 | self.url = url |
| 31 | self.delay = 0 |
| 32 | self.last_id = None |
| 33 | self.expected = count |
| 34 | self.received = 0 |
| 35 | self.accepted = 0 |
| 36 | self.db = Db("dst_db", EventInjector()) |
| 37 | |
| 38 | def on_start(self, event): |
| 39 | event.container.selectable(self.db.injector) |
nothing calls this directly
no test coverage detected