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):
303
303
raise MMQTTException ("Invalid broker address defined." , e )
304
304
305
305
# Fixed Header
306
- fixed_header = bytearray ()
307
- fixed_header .append (0x10 )
306
+ fixed_header = bytearray ([0x10 ])
308
307
309
308
# NOTE: Variable header is
310
309
# MQTT_HDR_CONNECT = bytearray(b"\x04MQTT\x04\x02\0\0")
@@ -688,21 +687,6 @@ def reconnect(self, resub_topics=True):
688
687
feed = subscribed_topics .pop ()
689
688
self .subscribe (feed )
690
689
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
-
706
690
def loop (self ):
707
691
"""Non-blocking message loop. Use this method to
708
692
check incoming subscription messages.
You can’t perform that action at this time.
0 commit comments