
    Ng                     N    d dl mZmZmZ d dlmZ d dlmZ  G d de          ZdS )    )AsyncIteratorIteratorList)Document)
BaseLoaderc                   N    e Zd ZdZdefdZdee         fdZde	e         fdZ
dS )MergedDataLoaderz&Merge documents from a list of loadersloadersc                     || _         dS )z!Initialize with a list of loadersN)r
   )selfr
   s     f/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/document_loaders/merge.py__init__zMergedDataLoader.__init__   s        returnc              #      K   | j         D ]E}	 |                                }n$# t          $ r |                                }Y nw xY w|D ]}|V  FdS 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      l 	 	F%''))& % % %{{}}%   	 	s   "AAc                b   K   | j         D ]$}|                                2 3 d{V }|W V  6 %dS r   )r
   
alazy_load)r   r   r   s      r   r   zMergedDataLoader.alazy_load   sj      l 	 	F"("3"3"5"5       h #6"5	 	s   -N)__name__
__module____qualname____doc__r   r   r   r   r   r   r    r   r   r	   r	      su        0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 0 0 0 0 0 0 0 0 - - - - - - @ @ @ @ @ @    z     r   