fixed chunk output

httpz_scanner/__init__.py

@@ -6,4 +6,4 @@ from .colors  import Colors
 from .scanner import HTTPZScanner
 
 
-__version__ = '2.1.1'
+__version__ = '2.1.2'

httpz_scanner/scanner.py

@@ -197,7 +197,7 @@ class HTTPZScanner:
             self.resolvers = await load_resolvers(self.resolver_file)
 
         async with aiohttp.ClientSession(connector=aiohttp.TCPConnector(ssl=False)) as session:
-            tasks = set()
+            tasks = {}  # Change to dict to track domain for each task
             domain_queue = asyncio.Queue()
             queue_empty = False
             
@@ -249,52 +249,44 @@ class HTTPZScanner:
             
             try:
                 while not queue_empty or tasks:
-                    # Fill up tasks to concurrent_limit
+                    # Start new tasks if needed
                     while len(tasks) < self.concurrent_limit and not queue_empty:
                         try:
                             domain = await domain_queue.get()
-                            if domain is None:  # Queue is empty
+                            if domain is None:
                                 queue_empty = True
                                 break
                             task = asyncio.create_task(process_domain(domain))
-                            tasks.add(task)
+                            tasks[task] = domain
-                        except asyncio.CancelledError:
-                            break
                         except Exception as e:
                             debug(f'Error creating task: {str(e)}')
                     
                     if not tasks:
                         break
-                    
+
-                    # Wait for any task to complete with timeout
+                    # Wait for the FIRST task to complete
                     try:
-                        done, pending = await asyncio.wait(
+                        done, _ = await asyncio.wait(
-                            tasks,
+                            tasks.keys(),
                             timeout=self.timeout,
                             return_when=asyncio.FIRST_COMPLETED
                         )
                         
-                        # Handle completed tasks
+                        # Process completed task immediately
                         for task in done:
-                            tasks.remove(task)
+                            domain = tasks.pop(task)
                             try:
                                 if result := await task:
                                     yield result
                             except Exception as e:
-                                debug(f'Error processing task result: {str(e)}')
+                                debug(f'Error processing result for {domain}: {str(e)}')
-                        
+                            
-                        # Handle timed out tasks
-                        if not done and pending:
-                            for task in pending:
-                                task.cancel()
-                                try:
-                                    await task
-                                except asyncio.CancelledError:
-                                    pass
-                                tasks.remove(task)
-                                
                     except Exception as e:
                         debug(f'Error in task processing loop: {str(e)}')
+                        # Remove any failed tasks
+                        failed_tasks = [t for t in tasks if t.done() and t.exception()]
+                        for task in failed_tasks:
+                            tasks.pop(task)
                     
             finally:
                 # Clean up

setup.py

@@ -10,7 +10,7 @@ with open('README.md', 'r', encoding='utf-8') as f:
 
 setup(
     name='httpz_scanner',
-    version='2.1.1',
+    version='2.1.2',
     author='acidvegas',
     author_email='acid.vegas@acid.vegas',
     description='Hyper-fast HTTP Scraping Tool',