(self)
Continually read events and command results
Continually read events and command results
Continually read events and command results
def _receive_thread(self):
        ''' Continually read events and command results '''
        while 1:
            try:
                msg = self._recv_msg()
                self.actors[msg['from']].put(msg)
            except Exception as e:
                print("disconnect: %s" % e)
                break
def _receive_thread ( self ) : while 1 : try : msg = self . _recv_msg ( ) self . actors [ msg [ 'from' ] ] . put ( msg ) except Exception as e : print ( "disconnect: %s" % e ) break