o
    Zh                     @   s@   d dl mZmZmZ d dlmZ d dlmZ G dd deZdS )    )AsyncIteratorIteratorList)Document)
BaseLoaderc                   @   sB   e Zd ZdZdefddZdee fddZde	e fdd	Z
d
S )MergedDataLoaderz&Merge documents from a list of loadersloadersc                 C   s
   || _ dS )z!Initialize with a list of loadersN)r   )selfr    r
   a/var/www/html/lang_env/lib/python3.10/site-packages/langchain_community/document_loaders/merge.py__init__   s   
zMergedDataLoader.__init__returnc              	   c   sJ    | j D ]}z| }W n ty   | }Y nw |D ]}|V  qqdS z+Lazy load docs from each individual loader.N)r   	lazy_loadNotImplementedErrorload)r	   loaderdatadocumentr
   r
   r   r      s   
zMergedDataLoader.lazy_loadc                 C  s0   | j D ]}| 2 z	3 dH W }|V  q
6 qdS r   )r   
alazy_load)r	   r   r   r
   r
   r   r      s   
zMergedDataLoader.alazy_loadN)__name__
__module____qualname____doc__r   r   r   r   r   r   r   r
   r
   r
   r   r      s
    r   N)	typingr   r   r   Zlangchain_core.documentsr   Z)langchain_community.document_loaders.baser   r   r
   r
   r
   r   <module>   s    