U :e@s6ddlZejZGdddejZGdddejZdS)Nc@s,eZdZddZddZddZddZd S) BaseStreamcCs|jrtddS)NzI/O operation on closed file)closed ValueErrorselfr1/usr/local/python38/lib/python3.8/_compression.py_check_not_closed szBaseStream._check_not_closedcCs|stddS)NzFile not open for reading)readableioUnsupportedOperationrrrr_check_can_readszBaseStream._check_can_readcCs|stddS)NzFile not open for writing)writabler r rrrr_check_can_writeszBaseStream._check_can_writecCs(|std|s$tddS)Nz3Seeking is only supported on files open for readingz3The underlying file object does not support seeking)r r r seekablerrrr_check_can_seeks zBaseStream._check_can_seekN)__name__ __module__ __qualname__r r rrrrrrr srcsfeZdZddZdddZfddZdd Zd d Zdd dZddZ e j fddZ ddZ ZS)DecompressReadercCsdS)NTrrrrrr $szDecompressReader.readablercKs>||_d|_d|_d|_||_||_|jf|j|_||_dS)NFr)_fp_eof_pos_size_decomp_factory _decomp_args _decompressor_trailing_error)rfpdecomp_factorytrailing_error decomp_argsrrr__init__'szDecompressReader.__init__csd|_tSN)rsupercloser __class__rrr&;szDecompressReader.closecCs |jSr$)rrrrrrr?szDecompressReader.seekablec CsPt|:}|d$}|t|}||dt|<W5QRXW5QRXt|S)NB) memoryviewcastreadlen)rbview byte_viewdatarrrreadintoBs$zDecompressReader.readintorcCs|dkr|S|r|jrdSd}|jjr|jjp<|jt}|sDq|jf|j |_z|j ||}Wq|j k rYqYqXn4|jj r|jt}|st dnd}|j ||}|r"qq"|sd|_|j|_dS|jt|7_|S)NrzACompressed file ended before the end-of-stream marker was reachedT)readallrreof unused_datarr, BUFFER_SIZErr decompressr needs_inputEOFErrorrrr-)rsizer1rawblockrrrr,Hs@     zDecompressReader.readcCs,|jdd|_d|_|jf|j|_dS)NrF)rseekrrrrrrrrr_rewindrs zDecompressReader._rewindcCs|tjkr nR|tjkr"|j|}n<|tjkrP|jdkrD|tjrDq6|j|}ntd |||jkrr| n ||j8}|dkr|t tj|}|sq|t |8}q||jS)NrzInvalid value for whence: {}) r SEEK_SETSEEK_CURrSEEK_ENDrr,DEFAULT_BUFFER_SIZErformatr>minr-)roffsetwhencer1rrrr=xs&          zDecompressReader.seekcCs|jSr$)rrrrrtellszDecompressReader.tell)r)r)rrrr r#r&rr2r,r>r r?r=rG __classcell__rrr'rr!s   *r)r rBr7BufferedIOBaser RawIOBaserrrrrs