

@gen_test
def test_join_timeout(self):
    q = self.queue_class()
    q.put(0)
    with self.assertRaises(TimeoutError):
        (yield q.join(timeout=timedelta(seconds=0.01)))

dataset/ETHPy150Open tornadoweb/tornado/tornado/test/queues_test.py QueueJoinTest.test_join_timeout/original