

@gen_test
def test_blocking_put_wait(self):
    q = queues.Queue(1)
    q.put_nowait(0)
    self.io_loop.call_later(0.01, futures.get)
    self.io_loop.call_later(0.02, q.get)
    futures = [q.put(0), q.put(1)]
    self.assertFalse(any((f.done() for f in futures)))
    (yield futures)

dataset/ETHPy150Open tornadoweb/tornado/tornado/test/queues_test.py QueuePutTest.test_blocking_put_wait/VarMisuse@37/48 `q`->`futures`