def METHOD_NAME(self):
    stream = self.router._stream_by_id[self.local.context_id]
    self.broker.stop_receive(stream)
    recv = self.local.call_async(time.sleep, 120)
    self.broker.defer(stream.on_disconnect, self.broker)
    exc = self.assertRaises(mitogen.core.ChannelError,
        lambda: recv.get())
    self.assertEqual(exc.args[0], self.router.respondent_disconnect_msg)