
    ih                     F    d dl mZmZmZ d dlmZ d dlmZ  G d de      Zy)    )AsyncIteratorIteratorList)Document)
BaseLoaderc                   @    e Zd ZdZdefdZdee   fdZde	e   fdZ
y)MergedDataLoaderz&Merge documents from a list of loadersloadersc                     || _         y)z!Initialize with a list of loadersN)r
   )selfr
   s     h/var/www/html/dev/engine/venv/lib/python3.12/site-packages/langchain_community/document_loaders/merge.py__init__zMergedDataLoader.__init__   s	        returnc              #      K   | j                   D ]  }	 |j                         }|D ]  }|    y# t        $ r |j                         }Y )w xY wwz+Lazy load docs from each individual loader.N)r
   	lazy_loadNotImplementedErrorload)r   loaderdatadocuments       r   r   zMergedDataLoader.lazy_load   s]     ll 	F%'') ! 	 ' %{{}%s%   A1AA
AAAc                r   K   | j                   D ]   }|j                         2 3 d{   }|  y7 6 (wr   )r
   
alazy_load)r   r   r   s      r   r   zMergedDataLoader.alazy_load   s?     ll 	F"("3"3"5  h	"5s    7535	757N)__name__
__module____qualname____doc__r   r   r   r   r   r   r    r   r   r	   r	      s3    0 	8H- 	-"9 r   r	   N)	typingr   r   r   langchain_core.documentsr   )langchain_community.document_loaders.baser   r	   r   r   r   <module>r#      s    0 0 - @z r   