

@gen_test
def test_blocking_get_wait(self):
    q = queues.Queue()
    q.put(0)
    self.io_loop.call_later(0.01, q.put, 1)
    self.io_loop.call_later(0.02, q.put, 2)
    self.assertEqual(0, (yield q.get(timeout=timedelta(seconds=1))))
    self.assertEqual(1, (yield q.get(timeout=timedelta(seconds=1))))

dataset/ETHPy150Open tornadoweb/tornado/tornado/test/queues_test.py QueueGetTest.test_blocking_get_wait/original