(self)
| 68 | |
| 69 | class QueueTest(unittest.TestCase): |
| 70 | def testDrainQueueAsync(self): |
| 71 | queue = Queue(1) |
| 72 | queue.put('foo') |
| 73 | with self.assertRaises(Full): |
| 74 | queue.put('bar', timeout=0.01) |
| 75 | with drain_queue_async(queue): |
| 76 | queue.put('bar') |
| 77 | with self.assertRaises(Empty): |
| 78 | queue.get(False) |
| 79 | |
| 80 | |
| 81 | if __name__ == '__main__': |
nothing calls this directly
no test coverage detected