code: def run(self):
          
          message_buffer = b""
          while self.running:
              try:
                  message_buffer += self.source.read_logs()
              except DataSourceError as e:
                  if self.running:
                      LOG.warn("Can't read logs from data source -- stopping: %s", e)
                  break
              except NotImplementedError as e:
                  LOG.info("%s doesn't support logging" % self)
                  break
  
              while True:
                  if "\x00" not in message_buffer:
                      break
                  record, _, remainder = message_buffer.partition(b"\x00")
                  self.record(record)
                  message_buffer = remainder
docs: Continuously read data from the source and attempt to parse a valid
          message from the buffer of bytes. When a message is parsed, passes it
          off to the callback if one is set.