def METHOD_NAME(self) -> None:
    while True:
        if self._stop_signal:
            self._clean_up()
            break
        if self._queue_length >= self.min_queue_length:
            self._call_callback_on_queue_data()
            self._queue_length = 0
        time.sleep(self._loop_sleep_time)
        if self.dataSet.completed:
            self._call_callback_on_queue_data()
            break