[stream-refactor] fix crash in runner/forking_active.yml

5 years ago · 93abbcaf7a
parent 1aceacf89e
commit 93abbcaf7a
2 changed files with 2 additions and 2 deletions
--- a/mitogen/master.py
+++ b/mitogen/master.py
@ -989,7 +989,7 @@ class ModuleResponder(object):

    def _send_forward_module(self, stream, context, fullname):
        if stream.protocol.remote_id != context.context_id:
-            stream.send(
+            stream.protocol._send(
                mitogen.core.Message(
                    data=b('%s\x00%s' % (context.context_id, fullname)),
                    handle=mitogen.core.FORWARD_MODULE,
--- a/mitogen/parent.py
+++ b/mitogen/parent.py
@ -2360,7 +2360,7 @@ class ModuleForwarder(object):
                  self, fullname, context_id, stream.protocol.remote_id)
        self._send_module_and_related(stream, fullname)
        if stream.protocol.remote_id != context_id:
-            stream._send(
+            stream.protocol._send(
                mitogen.core.Message(
                    data=msg.data,
                    handle=mitogen.core.FORWARD_MODULE,