B
    °F.\Î  ã               @   s<   d dl mZmZmZ d dlmZmZmZ dd„ Zdd„ Z	dS )é    )Úprint_functionÚdivisionÚabsolute_import)Úgzip_compressÚgzip_decompressÚfinalizec              C   s$   d} t | ƒ}t|ƒ}| |ks t‚d S )Ns   Hello, world!)r   r   ÚAssertionError)ÚbÚcÚd© r   úClib/python3.7/site-packages/distributed/tests/test_compatibility.pyÚ	test_gzip   s    r   c                 s¼   G dd„ dt ƒ} g ‰ ‡ fdd„}| ƒ }t||dƒ}|| ¡ ksBt‚d|_|| ¡ ksXt‚ˆ r`t‚~ˆ  ¡ dksrt‚| ƒ }t||dƒ}|jsŽt‚|ƒ  |jržt‚ˆ  ¡ dks®t‚~ˆ r¸t‚d S )Nc               @   s   e Zd ZdS )ztest_finalize.<locals>.CN)Ú__name__Ú
__module__Ú__qualname__r   r   r   r   ÚC   s   r   c                s   ˆ   | ¡ d S )N)Úappend)Úvalue)Úlr   r   Úcb   s    ztest_finalize.<locals>.cbé   Fé   )Úobjectr   Ú_select_for_exitr   ÚatexitÚpopÚalive)r   r   ÚoÚfZfinr   )r   r   Útest_finalize   s&    

r    N)
Z
__future__r   r   r   Zdistributed.compatibilityr   r   r   r   r    r   r   r   r   Ú<module>   s   