core: remove use of defer() from _async_route().

6 years ago · 692af860ba
parent 8676c40674
commit 692af860ba
1 changed files with 1 additions and 1 deletions
--- a/mitogen/core.py
+++ b/mitogen/core.py
@ -1273,7 +1273,7 @@ class Router(object):
                      self, msg, mitogen.context_id)
            return

-        stream.send(msg)
+        stream._send(msg)

    def route(self, msg):
        self.broker.defer(self._async_route, msg)