def METHOD_NAME(self):
    latch = mitogen.core.Latch()
    wait_recv = mitogen.core.Receiver(self.router)
    ts = [
        threading.Thread(target=lambda: self.wait(latch, wait_recv))
        for x in range(5)
    ]
    for t in ts:
        t.start()
    wait_recv.close()
    def throw():
        raise latch.get()
    for x in range(5):
        e = self.assertRaises(mitogen.core.ChannelError, throw)
        self.assertEqual(e.args[0], mitogen.core.Receiver.closed_msg)
    for t in ts:
        t.join()