Skip to content

Conversation

@spacewander
Copy link
Member

No description provided.


return _read_reply(self, sock)
local res, err = _read_reply(self, sock)
while _check_msg(res) do
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

maybe we should check the self. _subscribed?

return _read_reply(self, sock)
local res, err = _read_reply(self, sock)
while _check_msg(res) do
if rawget(self, "_unread_msg") == nil then
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

maybe _buffered_msgs will be a better name?

@spacewander
Copy link
Member Author

Updated.

@spacewander spacewander merged commit 3323079 into master Apr 20, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

3 participants