dataflux_core/fast_list.py [456:462]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    while True:
                        try:
                            result = results_queue.get_nowait()
                            results.update(result)
                            logging.debug(f"Result count: {len(results)}")
                        except queue.Empty:
                            break
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



dataflux_core/fast_list.py [596:602]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        while True:
            try:
                result = results_queue.get_nowait()
                results.update(result)
                logging.debug(f"Result count: {len(results)}")
            except queue.Empty:
                break
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -