From 918edf514594599fad9e1db85a584ca4bd498b88 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):