(self)
| 358 | |
| 359 | @gen_test |
| 360 | def test_join_timeout(self): |
| 361 | q = self.queue_class() # type: queues.Queue |
| 362 | q.put(0) |
| 363 | with self.assertRaises(TimeoutError): |
| 364 | yield q.join(timeout=timedelta(seconds=0.01)) |
| 365 | |
| 366 | |
| 367 | class PriorityQueueJoinTest(QueueJoinTest): |