+
    LV-j  ã                   óz  € R t ^ RIt^ RIHt ^ RIt^ RIHt R tR]/t	RR lt
R R lt]
! R]R4        ^ RIHt ]
! R	]R	4        ^ R
IHt R!R lt]
! R]R4        ^ RIHt ]
! R]R4       ]
! R]R4        ^ RIt]
! R]P(                  RRR7       ]
! R]P(                  RRR7        ! R R]4      t ^ RIt]P0                  ! R4       ]
! R]. 4        ^ RIt]
! R]P:                  P<                  R4        ]P>                  R"8¼  d   ^ RI H!t! M^ RI"H!t! ]
! R]!PF                  R4       R t&R#   ] d     Lòi ; i  ] d    ^ RIHt ]
! RR R4        Lúi ; i  ] d     Lìi ; i  ] d     LÈi ; i  ]]]3 d     L¬i ; i  ] d     L–i ; i  ] d&     ^ RI$t!R!R lt%]
! R]%R4       M  ] d     Mi ; i L’i ; i)#z9Helper functions for a standard streaming compression APIN)ÚZipFile)ÚAbstractBufferedFilec                 ó   € V # ©N© )ÚfileÚmodeÚkwargss   &&,Úc/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/fsspec/compression.pyÚ	noop_filer   
   s   € Ø€Kó    c                ó`  € \        V\        4      '       d   V.pV \        9   d   V'       g   \        RV  24      hV F>  pV\        P
                  P                  9   g   K$  V'       d   K.  \        RV RV  R24      h	  V\        V &   V F   pV \        P
                  P                  V&   K"  	  R# )a	  Register an "inferable" file compression type.

Registers transparent file compression type for use with fsspec.open.
Compression can be specified by name in open, or "infer"-ed for any files
ending with the given extensions.

Args:
    name: (str) The compression type name. Eg. "gzip".
    callback: A callable of form (infile, mode, **kwargs) -> file-like.
        Accepts an input file-like object, the target mode and kwargs.
        Returns a wrapped file-like object.
    extensions: (str, Iterable[str]) A file extension, or list of file
        extensions for which to infer this compression scheme. Eg. "gz".
    force: (bool) Force re-registration of compression type or extensions.

Raises:
    ValueError: If name or extensions already registered, and not force.

z$Duplicate compression registration: z&Duplicate compression file extension: z (Ú)N)Ú
isinstanceÚstrÚcomprÚ
ValueErrorÚfsspecÚutilsÚcompressions)ÚnameÚcallbackÚ
extensionsÚforceÚexts   &&&& r
   Úregister_compressionr      s›   € ô( �*œc×"Ò"Ø �\ˆ
ð Œu„}ŸUÜÐ?À¸vÐFÓGÐGãˆØ”&—,‘,×+Ñ+Ö+·E±EÜÐEÀcÀUÈ"ÈTÈFÐRSÐTÓUÐUñ ð „Eˆ$�KãˆØ)-Œ�‰×!Ñ! #Ó&ó r   c                 ó  a€ R V9  dH   T;'       g    Rp\        V 3RR/VB oSP                  VRR7      pVP                  3V3R llVn        V# \        V 4      oVf   SP                  4       ^ ,          pSP                  ! V3RR /VB # )Úrr   r   Úw)r   c                 óB   <€ V ! 4       ;'       g    SP                  4       # r   )Úclose)ÚcloserÚzs   &€r
   Ú<lambda>Úunzip.<locals>.<lambda>=   s   ø€ ©6«8×+@Ð+@°q·w±w³yÐ+@r   )r   Úopenr    Únamelist)Úinfiler   Úfilenamer	   Úfor"   s   &&&, @r
   Úunzipr*   8   s‡   ø€ Ø
�$„Ø×%Ð%˜vˆÜ�FÑ/ Ð/¨Ñ/ˆØ�V‰V�H 3ˆVÓ'ˆØ!#§¡Ö@ˆŒØˆ	Ü�‹€AØÒØ—:‘:“< •?ˆØ�6Š6�(Ñ/ Ð/¨Ñ/Ð/r   Úzip)ÚBZ2FileÚbz2)Úigzipc                 ó6   € \         P                  ! RR V RV/VB # )Úfileobjr   r   )r.   Ú	IGzipFile)r'   r   r	   s   &&,r
   Úisalr2   Q   s   € Ü�ŠÑC vÐC°DÐC¸FÑCÐCr   ÚgzipÚgz©ÚGzipFilec                 ó   € \        RR V /VB # )r0   r   r5   )Úfr	   s   &,r
   r#   r#   Y   s   € ¤HÑ$A°QÐ$A¸&Ò$Ar   )ÚLZMAFileÚlzmaÚxzT)r   c                   óR   a a€ ] tR t^mt oV 3R ltRR ltRR ltR tR tRt	Vt
V ;t# )	Ú
SnappyFilec                óâ   <€ ^ RI p\        SV `  ! R
RRRRRVP                  R4      R,           RR/VB  Wn        R	V9   d   VP
                  ! 4       V n        R# VP                  ! 4       V n        R# )é    NÚfsÚpathÚsnappyr   ÚbÚsizeiÿÉš;r   r   )rB   ÚsuperÚ__init__Ústripr'   ÚStreamDecompressorÚcodecÚStreamCompressor)Úselfr'   r   r	   rB   Ú	__class__s   &&&, €r
   rF   ÚSnappyFile.__init__n   sv   ø€ Ûä‰Òñ 	
Øð	
Ø"ð	
Ø)-¯©°C«¸3Õ)>ð	
ØENð	
ØRXò	
ð ŒØ�$Œ;Ø×2Ò2Ó4ˆDŽJà×0Ò0Ó2ˆDŽJr   c                óØ   € V P                   P                  ^ 4       V P                  P                  V P                   P	                  4       4      pV P
                  P                  V4       R# )r?   T)ÚbufferÚseekrI   Ú	add_chunkÚreadr'   Úwrite)rK   ÚfinalÚouts   && r
   Ú_upload_chunkÚSnappyFile._upload_chunkz   sJ   € Ø�‰×Ñ˜ÔØ�j‰j×"Ñ" 4§;¡;×#3Ñ#3Ó#5Ó6ˆØ�‰×Ñ˜#ÔÙr   c                ó   € \        R 4      h)zSnappyFile is not seekable)ÚNotImplementedError)rK   ÚlocÚwhences   &&&r
   rP   ÚSnappyFile.seek€   s   € Ü!Ð">Ó?Ð?r   c                ó   € R # ©Fr   )rK   s   &r
   ÚseekableÚSnappyFile.seekableƒ   s   € Ùr   c                óz   € V P                   P                  W!,
          4      pV P                  P                  V4      # )z*Get the specified set of bytes from remote)r'   rR   rI   Ú
decompress)rK   ÚstartÚendÚdatas   &&& r
   Ú_fetch_rangeÚSnappyFile._fetch_range†   s-   € à�{‰{×Ñ ¥Ó,ˆØ�z‰z×$Ñ$ TÓ*Ð*r   )rI   r'   r^   )r?   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__rF   rV   rP   r_   rf   Ú__static_attributes__Ú__classdictcell__Ú__classcell__)rL   Ú__classdict__s   @@r
   r=   r=   m   s$   ù‡ € õ
3ôô@ò÷+ò +r   r=   r   rB   Úlz4)Úzstdrq   Úzstc                 ó¬   € R V9   d'   \         P                  ! 4       pVP                  V 4      # \         P                  ! ^
R7      pVP	                  V 4      # )r   )Úlevel)rq   ÚZstdDecompressorÚstream_readerÚZstdCompressorÚstream_writer)r'   r   Úcctxs   && r
   Úzstandard_filerz   ©   sI   € Ø�dŒ{Ü×,Ò,Ó.�Ø×)Ñ)¨&Ó1Ð1ä×*Ò*°Ô4�Ø×)Ñ)¨&Ó1Ð1r   c                 ó    € \        \        4      # )z.Return a list of the implemented compressions.)Úlistr   r   r   r
   Úavailable_compressionsr}   ·   s   € ä”‹;Ðr   r^   )ÚrbN)r~   )é   é   )'Ú__doc__ÚsysÚzipfiler   Úfsspec.utilsr   Úfsspec.specr   r   r   r   r*   r-   r,   ÚImportErrorr2   r.   r3   r6   r:   r9   Úlzmaffir=   rB   ÚcompressÚ	NameErrorÚAttributeErrorÚ	lz4.framerp   Úframer%   Úversion_infoÚcompressionrq   Ú	backportsÚZstdFileÚ	zstandardrz   r}   r   r   r
   Ú<module>r’      s  ðÙ ?ã 
Ý ã Ý ,òð 
ˆyÐ€ô".ôJ
0ñ �U˜E 5Ô )ð0Ýñ ˜ ¨Ô/ðÝôDñ ˜  tÔ,ð	Ýá˜ ¨6Ô2Ù˜˜x¨Ô.ð	Ûá˜ ×!1Ñ!1°6ÀÕFÙ˜˜w×/Ñ/°¸TÕBô
+Ð%ô +ð>		Ûà
‡O‚O�CÔñ ˜ :¨rÔ2ð
	Ûá˜ §	¡	§¡°Ô6ð	Ø
×Ñ˜7Ô"Þ$å"á˜ §¡°Ô6ô&øð] ô 	Ùð	ûð ô ÝáØÑAÀ4öðûð ô 	Ùð	ûð ô 	Ùð	ûðV 	�Y Ð/ô 	Ùð	ûð ô 	Ùð	ûð ô 	ðÛ ô	2ñ 	˜V ^°UÕ;øØô Ùðúáð	ús¡   ³D, ÁD9 ÁE Á50E$ Â1 E1 Ã"F Ã52F Ä,D6Ä5D6Ä9EÅEÅE!Å E!Å$E.Å-E.Å1
E>Å=E>ÆFÆ
FÆF:ÆF*Æ)F:Æ*F4Æ1F:Æ3F4Æ4F:Æ9F: