ó
¦–Õ\c           @   si   d  d l  m Z d  d l Z d  d l m Z m Z m Z d „  Z e j j	 d e j
 ƒ  ƒ d „  ƒ Z d S(   iÿÿÿÿ(   t   BytesION(   t   compresst
   decompresst   filesc          C   s˜   t  t ƒ t  t ƒ k s t ‚ d }  xm t D]e } t | } t | } | |  ƒ } | | ƒ } |  | k so t ‚ | d  k	 r+ |  | k s t ‚ q+ q+ Wd  S(   Ns   Hello, world!(   t   setR   R   t   AssertionErrort   None(   t   at   kt   compt   decompt   bt   c(    (    s@   lib/python2.7/site-packages/dask/bytes/tests/test_compression.pyt   test_compression   s    

s   fmt,Filec   	      C   sÍ   |  d  k r d  Sd d } t ƒ  } | | d d ƒ} | j | ƒ | j ƒ  | j d ƒ | j ƒ  } t | ƒ t | ƒ k sƒ t ‚ t | ƒ } | | d d ƒ} | j ƒ  } | j ƒ  | | k sÉ t ‚ d  S(   Nt   1234iè  t   modet   wbi    t   rb(   R   R    t   writet   closet   seekt   readt   lenR   (	   t   fmtt   Filet   datat   outt   ft
   compressedR   t   gt   data2(    (    s@   lib/python2.7/site-packages/dask/bytes/tests/test_compression.pyt
   test_files   s    
	

(   t   ioR    t   pytestt   dask.bytes.compressionR   R   R   R   t   markt   parametrizet   itemsR   (    (    (    s@   lib/python2.7/site-packages/dask/bytes/tests/test_compression.pyt   <module>   s   	