(self)
Command processing loop, run until program exit
Command processing loop, run until program exit
Command processing loop run until program exit
async def process_command_q(self):
        '''
        Command processing loop, run until program exit
        '''
        while True:
            value = await self.command_q.get()
            command = value.get('command')
            setting = value.get('setting')
            schedule = value.get('schedule')
            if command:
                await self.loop.run_in_executor(None, self._send_command, command)
            if setting:
                await self.loop.run_in_executor(None, self._set_preference, *setting)
            if schedule:
                await self.loop.run_in_executor(None, self._set_cleanSchedule, schedule)
            self.command_q.task_done()
async def process_command_q ( self ) : while True : value = await self . command_q . get ( ) command = value . get ( 'command' ) setting = value . get ( 'setting' ) schedule = value . get ( 'schedule' ) if command : await self . loop . run_in_executor ( None , self . _send_command , command ) if setting : await self . loop . run_in_executor ( None , self . _set_preference , * setting ) if schedule : await self . loop . run_in_executor ( None , self . _set_cleanSchedule , schedule ) self . command_q . task_done ( )