+
    Pj                     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     Li ; i  ] d    ^ RIHt ]
! RR R4        Li ; i  ] d     Li ; i  ] d     Li ; i  ]]]3 d     Li ; i  ] d     Li ; i  ] d&     ^ RI$t!R!R lt%]
! R]%R4       M  ] d     Mi ; i Li ; i)#z9Helper functions for a standard streaming compression APIN)ZipFile)AbstractBufferedFilec                     V # N )filemodekwargss   &&,k/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.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&,,+++EEEcU"TFRS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    68+@+@qwwy+@r   )r   openr    namelist)infiler   filenamer	   for"   s   &&&, @r
   unzipr*   8   s    
$%%vF///VVH3V'!#@	A::<?66(////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    CvCDCFCCr   gzipgzGzipFilec                     \        RR V /VB # )r0   r   r5   )fr	   s   &,r
   r#   r#   Y   s    H$AQ$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4DJ002DJr   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    jj""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-    {{,zz$$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 UE5 )0 /D t,	62x.	!1!16Fw//TB
+% +>		
OOC :r2
			6	
7"$"6&]  		  A4  		  		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: