(self, kc, kill_sema)
| 43 | |
| 44 | class FlushingThread(threading.Thread): |
| 45 | def __init__(self, kc, kill_sema): |
| 46 | threading.Thread.__init__(self) |
| 47 | self.kill_sema = kill_sema |
| 48 | self.kc = kc |
| 49 | |
| 50 | def run(self): |
| 51 | logger.info("Running message flusher...") |
nothing calls this directly
no outgoing calls
no test coverage detected