def testOutputConsumedMessageTimeout(self):
        self.rdm.addMessage(self.theMessage)
        self.rdm.addOutput(mappend(self.transport))

        n, f, a, kw = self.scheduled.pop()
        self.failIf(self.scheduled, "Too many tasks scheduled.")

        self.assertEquals(n, self.transportlessTimeout)
        f(*a, **kw)

        self.assertEquals(len(self.events), 1)
        self.events[0].trap(athena.ConnectionLost)

        self.failIf(self.scheduled, "Unexpected task scheduled after connection lost.")
Delete the annotation with the given id.
dataset/ETHPy150Open twisted/nevow/nevow/test/test_athena.py/Transport.testOutputConsumedMessageTimeout--crossover with--dataset/ETHPy150Open hypothesis/h/h/api/storage.py/delete_annotation