code: async def _process_msgs(self):
          
          while True:
              args = await self._msgq.get()
              _LOGGER.debug('Processing: %s %02x %s %s %s', args[0], args[1],
                            *[args[i].hex() for i in range(2, 5)])
              await self._process_msg(*args)
docs: Get messages from the queue and pass them to _process_msg().
          Make sure we process one message at a time to keep them in sequence.