

def test_drain_events(self):
    with self.assertRaises(socket.timeout):
        self.c.drain_events(timeout=0.1)
    c1 = self.c.channel()
    c2 = self.c.channel()
    with self.assertRaises(socket.timeout):
        self.c.drain_events(timeout=0.1)
    del c1
    del c2

dataset/ETHPy150Open celery/kombu/kombu/tests/transport/test_memory.py test_MemoryTransport.test_drain_events/original