code: def process(self, blob):
          
          # self._add_process_dt()
          try:
              log.debug("Waiting for queue items.")
              prefix, data = self.queue.get(timeout=self.timeout)
              log.debug("Got {0} bytes from queue.".format(len(data)))
          except Empty:
              log.warning(
                  "ControlHost timeout ({0}s) reached".format(self.timeout)
              )
              raise StopIteration("ControlHost timeout reached.")
          blob[self.key_for_prefix] = prefix
          blob[self.key_for_data] = data
          return blob
docs: Wait for the next packet and put it in the blob