o
    Si                     @   sX   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d Zd	S )
    )fold)reduce)add)dumpsloads)Pool__no__default__c                  C   s2  t ttddtttddksJ t } t ttdd| jdtttddks+J W d    n1 s5w   Y  t ttddddtttddksNJ t ttdt ttddks_J dd }t |g dt h d	ksrJ t |g dt dtjd
h d	ksJ t ttdtdt ttdksJ d S )N
   r   )map   )	chunksizec                 S   s   |   } | | | S )N)copyr   )sitem r   U/home/ubuntu/.local/lib/python3.10/site-packages/toolz/sandbox/tests/test_parallel.pysetadd   s   
ztest_fold.<locals>.setadd)   r      >   r   r   r   )r   combine)default)	r   r   ranger   r   r
   setunionno_default2)poolr   r   r   r   	test_fold   s   $,("(r   N)toolz.sandbox.parallelr   toolzr   operatorr   pickler   r   multiprocessingr   r   r   r   r   r   r   <module>   s    