Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

adjust fixed_header init; (-) loop_forever() #46

Merged
merged 5 commits into from
Aug 6, 2020
Merged

adjust fixed_header init; (-) loop_forever() #46

Changes from 1 commit
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
285e0da
adjust fixed_header init; (-) loop_forever()
2bndy5 Jul 21, 2020
1cad196
pub_hdr_fixed & pub_hdr_var simplified init
2bndy5 Jul 26, 2020
044d06c
pleasing black
2bndy5 Jul 26, 2020
d938bc0
(-) MQTT_PUB const; fixed pub_hdr_var.append()
2bndy5 Jul 29, 2020
2c790c0
extend() actually works better with a bytes object
2bndy5 Jul 29, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 1 addition & 17 deletions adafruit_minimqtt/adafruit_minimqtt.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -303,8 +303,7 @@ def connect(self, clean_session=True):
raise MMQTTException("Invalid broker address defined.", e)

# Fixed Header
fixed_header = bytearray()
fixed_header.append(0x10)
fixed_header = bytearray([0x10])
2bndy5 marked this conversation as resolved.
Show resolved Hide resolved

# NOTE: Variable header is
# MQTT_HDR_CONNECT = bytearray(b"\x04MQTT\x04\x02\0\0")
Expand Down Expand Up @@ -688,21 +687,6 @@ def reconnect(self, resub_topics=True):
feed = subscribed_topics.pop()
self.subscribe(feed)

def loop_forever(self):
2bndy5 marked this conversation as resolved.
Show resolved Hide resolved
"""Starts a blocking message loop. Use this
method if you want to run a program forever.
Code below a call to this method will NOT execute.

.. note:: This method is depreciated and will be removed in the
next major release. Please see
`examples/minimqtt_pub_sub_blocking.py <examples.html#basic-forever-loop>`_
for an example of creating a blocking loop which can handle wireless
network events.
"""
while True:
if self._sock.connected:
self.loop()

def loop(self):
"""Non-blocking message loop. Use this method to
check incoming subscription messages.
Expand Down