
    dh                     F    S SK JrJrJr  S SKJr  S SKJr   " S S\5      rg)    )AsyncIteratorIteratorList)Document)
BaseLoaderc                   N    \ rS rSrSrS\4S jrS\\   4S jr	S\
\   4S jrSrg	)
MergedDataLoader   z&Merge documents from a list of loadersloadersc                     Xl         g)z!Initialize with a list of loadersNr   )selfr   s     b/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/document_loaders/merge.py__init__MergedDataLoader.__init__   s        returnc              #      #    U R                    H!  n UR                  5       nU H  nUv   M	     M#     g! [         a    UR                  5       n N.f = f7fz+Lazy load docs from each individual loader.N)r   	lazy_loadNotImplementedErrorload)r   loaderdatadocuments       r   r   MergedDataLoader.lazy_load   sR     llF%'') ! ! # ' %{{}%s%   A5AAAAAc                x   #    U R                    H!  nUR                  5         Sh  vN nU7v   M     g N
 M+  7fr   )r   
alazy_load)r   r   r   s      r   r   MergedDataLoader.alazy_load   s3     llF"("3"3"5 h #"5s    :757:7:r   N)__name__
__module____qualname____firstlineno____doc__r   r   r   r   r   r   r   __static_attributes__ 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   