diff --git a/mitogen/core.py b/mitogen/core.py index d87baf36..d5044307 100644 --- a/mitogen/core.py +++ b/mitogen/core.py @@ -1287,7 +1287,7 @@ class Router(object): if respondent: assert policy is None def policy(msg, _stream): - return msg.src_id == respondent.context_id + return msg.is_dead or msg.src_id == respondent.context_id def on_disconnect(): if handle in self._handle_map: fn(Message.dead())