(self)
| 56 | self.running = True |
| 57 | |
| 58 | def run(self): |
| 59 | self.queue = queue.Queue() |
| 60 | self.cache = {} |
| 61 | # Wait for full market initialization (otherwise there's high risky |
| 62 | # this thread will attempt to init Market which is already being inited) |
| 63 | mktRdy.wait(5) |
| 64 | self.processRequests() |
| 65 | |
| 66 | def processRequests(self): |
| 67 | queue = self.queue |
nothing calls this directly
no test coverage detected