File tree Expand file tree Collapse file tree 1 file changed +1
-17
lines changed Expand file tree Collapse file tree 1 file changed +1
-17
lines changed Original file line number Diff line number Diff line change @@ -303,8 +303,7 @@ def connect(self, clean_session=True):
303303 raise MMQTTException ("Invalid broker address defined." , e )
304304
305305 # Fixed Header
306- fixed_header = bytearray ()
307- fixed_header .append (0x10 )
306+ fixed_header = bytearray ([0x10 ])
308307
309308 # NOTE: Variable header is
310309 # MQTT_HDR_CONNECT = bytearray(b"\x04MQTT\x04\x02\0\0")
@@ -688,21 +687,6 @@ def reconnect(self, resub_topics=True):
688687 feed = subscribed_topics .pop ()
689688 self .subscribe (feed )
690689
691- def loop_forever (self ):
692- """Starts a blocking message loop. Use this
693- method if you want to run a program forever.
694- Code below a call to this method will NOT execute.
695-
696- .. note:: This method is depreciated and will be removed in the
697- next major release. Please see
698- `examples/minimqtt_pub_sub_blocking.py <examples.html#basic-forever-loop>`_
699- for an example of creating a blocking loop which can handle wireless
700- network events.
701- """
702- while True :
703- if self ._sock .connected :
704- self .loop ()
705-
706690 def loop (self ):
707691 """Non-blocking message loop. Use this method to
708692 check incoming subscription messages.
You can’t perform that action at this time.
0 commit comments