
    bi                     f    d dl mZ d dlmZ d dlmZ d dlmZmZ d dl	m
Z
  e ed            Zd Zy)	    )fold)reduce)add)dumpsloads)Pool__no__default__c                  .   t        t        t        d      d      t        t        t        d      d      k(  sJ t	               5 } t        t        t        d      d| j
                        t        t        t        d      d      k(  sJ 	 d d d        t        t        t        d      dd      t        t        t        d      d      k(  sJ t        t        t        d            t        t        t        d      d      k(  sJ d }t        |g dt                     h dk(  sJ t        |g dt               dt        j                  	      h dk(  sJ t        t        t        d      t        
      t        t        t        d            k(  sJ y # 1 sw Y   xY w)N
   r   )map   )	chunksizec                 H    | j                         } | j                  |       | S )N)copyr   )sitems     \/home/cdr/jupyterlab/.venv/lib/python3.12/site-packages/toolz/sandbox/tests/test_parallel.pysetaddztest_fold.<locals>.setadd   s    FFH	d    )   r      >   r   r   r   )r   combine)default)	r   r   ranger   r   r   setunionno_default2)poolr   s     r   	test_foldr      s:   U2Y"fS%)Q&????	 R4CrA4884sE"Iq8QQQQR U2YQ/6#uRy!3LLLLU2Y4U2Y#::::
 	35)Y666CEQ		J   U2Y4S%)8LLLLR Rs   AF

FN)toolz.sandbox.parallelr   toolzr   operatorr   pickler   r   multiprocessingr   r   r    r   r   <module>r&      s,    '      E+,-Mr   