From e7673e72f6b6d315d8decbdc31a7db5a7532e314 Mon Sep 17 00:00:00 2001 From: David Wilson Date: Mon, 18 Sep 2017 14:44:17 +0530 Subject: [PATCH] Add TODO --- mitogen/core.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mitogen/core.py b/mitogen/core.py index 59ae962a..4cbf5ef3 100644 --- a/mitogen/core.py +++ b/mitogen/core.py @@ -644,7 +644,7 @@ class Stream(BasicStream): pkt = struct.pack('>hhLLL', msg.dst_id, msg.src_id, msg.handle, msg.reply_to or 0, len(msg.data) ) + msg.data - self._output_buf += pkt + self._output_buf += pkt # TODO: It's actually possible for this to race self._router.broker.start_transmit(self) def on_disconnect(self, broker):