#NEWLINE# @ pytest . mark . parametrize ( 'fmt,blocksize' , fmt_bs ) #NEWLINE# def test_compression( fmt , blocksize ) : #NEWLINE# #INDENT# compress = compression . compress [ fmt ] #NEWLINE# files2 = valmap ( compress , files ) #NEWLINE# with filetexts ( files2 , mode = 'b' ) : #NEWLINE# #INDENT# ( sample , values ) = read_bytes ( '.test.accounts.*.json' , blocksize = blocksize , delimiter = b'\n' , compression = fmt ) #NEWLINE# assert ( sample [ : 5 ] == files [ sorted ( files ) [ 0 ] ] [ : 5 ] ) #NEWLINE# results = compute ( * concat ( values ) ) #NEWLINE# assert ( b'' . join ( results ) == b'' . join ( [ files [ k ] for k in sorted ( files ) ] ) )