From fac2c6ea5240e48f187acc81efe89406fc376ce8 Mon Sep 17 00:00:00 2001 From: Jan Vlcinsky Date: Mon, 30 Oct 2017 17:33:41 +0100 Subject: [PATCH] Fix issue #95 Randomly incomplete topic name in consuming from MQTT topic. --- hbmqtt/adapters.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/hbmqtt/adapters.py b/hbmqtt/adapters.py index 090a518..39481ce 100644 --- a/hbmqtt/adapters.py +++ b/hbmqtt/adapters.py @@ -140,7 +140,11 @@ class StreamReaderAdapter(ReaderAdapter): @asyncio.coroutine def read(self, n=-1) -> bytes: - return (yield from self._reader.read(n)) + if n == -1: + data = yield from self._reader.read(n) + else: + data = yield from self._reader.readexactly(n) + return data def feed_eof(self): return self._reader.feed_eof()