core: Allow dead messages to be delivered regardless of policy

pull/242/head
David Wilson 6 years ago
parent 3203846708
commit 79346d96db

@ -1287,7 +1287,7 @@ class Router(object):
if respondent: if respondent:
assert policy is None assert policy is None
def policy(msg, _stream): 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(): def on_disconnect():
if handle in self._handle_map: if handle in self._handle_map:
fn(Message.dead()) fn(Message.dead())

Loading…
Cancel
Save