

@gen_test
def test_task_done_delay(self):
    q = self.queue_class()
    q.put_nowait(0)
    join = q.join()
    self.assertFalse(self.done())
    (yield q.get())
    self.assertFalse(join.done())
    (yield gen.moment)
    self.assertFalse(join.done())
    q.task_done()
    self.assertTrue(join.done())

dataset/ETHPy150Open tornadoweb/tornado/tornado/test/queues_test.py QueueJoinTest.test_task_done_delay/VarMisuse@40/49 `join`->`self`