We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f8411de commit de92f3cCopy full SHA for de92f3c
mqtt/connector/base/buffered_base.lua
@@ -46,7 +46,7 @@ function buffered:receive(size)
46
47
while size > (#buf - idx) do
48
-- buffer is lacking bytes, read more...
49
- local data, err = self:plain_receive(#buf - idx + size)
+ local data, err = self:plain_receive(size - (#buf - idx))
50
if not data then
51
if err == self.signal_idle then
52
-- read timedout, retry entire packet later, reset buffer
0 commit comments