Conditions | 3 |
Total Lines | 16 |
Lines | 0 |
Ratio | 0 % |
1 | import queue |
||
20 | def test_run(self): |
||
21 | log_printer = TestPrinter() |
||
22 | log_queue = queue.Queue() |
||
23 | self.uut = LogPrinterThread(log_queue, log_printer) |
||
24 | log_queue.put(item="Sample message 1") |
||
25 | log_queue.put(item="Sample message 2") |
||
26 | log_queue.put(item="Sample message 3") |
||
27 | self.assertEqual(self.uut.message_queue.qsize(), 3) |
||
28 | with retrieve_stdout() as stdout: |
||
29 | self.uut.start() |
||
30 | while self.uut.message_queue.qsize() > 0: |
||
31 | continue |
||
32 | self.uut.running = False |
||
33 | self.uut.join() |
||
34 | self.assertEqual(stdout.getvalue(), |
||
35 | "Sample message 1\nSample message 2\nSample " |
||
36 | "message 3\n") |
||
37 |