endpoint.request() should raise when a result is no longer possible

[carver]

What was wrong?

Code that produced the error

I have some code that hangs when the other endpoint disconnects:

await event_bus.request(...)

Note: this happens inside of a:

future = asyncio.run_coroutine_threadsafe(...)
future.result(300)

But I don't think that makes a difference. Obviously it will eventually give up at the end of the timeout, but due to the nature of the call, it's unreasonable to tighten the timeout and give up early.

Actual Result

This code hangs until the future times out.

Expected Result

An exception to be raised, something like a ConnectionLost, if it becomes impossible to receive a response. (Maybe the right terminology is: if there are no more subscribers?)

Environment

lahja v0.14.0

How can it be fixed?

🤷‍♂️