vKgvSSKrSSKrSSKJr SSKJr "SS\R 5rSrSr S Sjr S S jr g) N)error)univc\rSrSrSrSrSrSrS\R4Sjr SSjr \ S 5r \ RS 5r S rS rg )CachingStreamWrapper aWrapper around non-seekable streams. Note that the implementation is tied to the decoder, not checking for dangerous arguments for the sake of performance. The read bytes are kept in an internal cache until setting _markedPosition which may reset the cache. cRXl[R"5UlSUlgNr)_rawioBytesIO_cache_markedPosition)selfraws V/var/www/highfloat_scraper/venv/lib/python3.13/site-packages/pyasn1/codec/streaming.py__init__CachingStreamWrapper.__init__s jjl  cURU5nURR[U5*[R 5 U$N)readr seeklenosSEEK_CUR)rnresults rpeekCachingStreamWrapper.peeks21 #f+r{{3 rcg)NTrs rseekableCachingStreamWrapper.seekable!src8URRX5$r)r r)rrwhences rrCachingStreamWrapper.seek$s{{**rcURRU5nUS:waU[U5-nU(dU$URRU5nURR U5 X#-$)Nr%)r rrr write)rrread_from_cache read_from_raws rrCachingStreamWrapper.read(sb++**1- 7 _% %A&& q)  -(..rcUR$)zPosition where the currently processed element starts. This is used for back-tracking in SingleItemDecoder.__call__ and (indefLen)ValueDecoder and should not be used for other purposes. The client is not supposed to ever seek before this position. )rr"s rmarkedPosition#CachingStreamWrapper.markedPosition5s###rcXlURR5[R:a;[R "URR 55UlSUlggr )rr tellr DEFAULT_BUFFER_SIZEr r)rvalues rr/r0?sQ % ;;    6 6 6**T[[%5%5%78DK#$D  7rc6URR5$r)r r2r"s rr2CachingStreamWrapper.tellMs{{!!r)r rr Nr%)__name__ __module__ __qualname____firstlineno____doc__rrr#rSEEK_SETrrpropertyr/setterr2__static_attributes__r!rrrr s^!   + /$$ % %"rrc[U[R5(aU$[U[5(a[R"U5$[U[R 5(a$[R"UR 55$UR5(aU$[U5$![a1 [R"SURR-S-5ef=f)a=Convert object to seekable byte-stream. Parameters ---------- substrate: :py:class:`bytes` or :py:class:`io.IOBase` or :py:class:`univ.OctetString` Returns ------- : :py:class:`io.IOBase` Raises ------ : :py:class:`~pyasn1.error.PyAsn1Error` If the supplied substrate cannot be converted to a seekable stream. zCannot convert z to a seekable bit stream.) isinstancer r bytesr OctetStringasOctetsr#rAttributeErrorrUnsupportedSubstrateError __class__r8) substrates rasSeekableStreamrJQs )RZZ(( Iu % %zz)$$ It// 0 0zz),,.// *      ' 2 2 *--  3 3 < < < ( )* **sB3( B33;C.c## [U[R5(ahUR5nUR S[ R 5 UR5U:HnUR U[ R5 Uv gURS5nUcSv U(a UR S[ R5 U(+v g7f)zCheck whether we have reached the end of a stream. Although it is more effective to read and catch exceptions, this function Parameters ---------- substrate: :py:class:`IOBase` Stream to check Returns ------- : :py:class:`bool` rNr%) rBr r r2rrSEEK_ENDr=rr)rIcprreceiveds r isEndOfStreamrPvs)RZZ(( ^^ q"++&!R'r2;;' >>!$     NN2r{{ +lsCCc#L# [US5(aAURU5nUcSv [U5U:aSv [U5U:aMUv gUR5n[ X5HnUv M UR U5 g!UR U5 f=f7f)aPeek into stream. Parameters ---------- substrate: :py:class:`IOBase` Stream to read from. size: :py:class:`int` How many bytes to peek (-1 = all available) Returns ------- : :py:class:`bytes` or :py:class:`str` The return type depends on Python major version rN)hasattrrrr2readFromStreamr)rIsizerOcurrent_positionchunks rpeekIntoStreamrWs y&!!>>$'   (md" (md"%>>+ -' 8 9 NN+ ,INN+ ,s$A B$B$&B<B$B!!B$c#T# URU5nUc[R"US9v OrU(dUS:wa[R"US9e[ U5U:aAUR [ U5*[ R5 [R"US9v OOMUv g7f)aRead from the stream. Parameters ---------- substrate: :py:class:`IOBase` Stream to read from. Keyword parameters ------------------ size: :py:class:`int` How many bytes to read (-1 = all available) context: :py:class:`dict` Opaque caller context will be attached to exception objects created by this function. Yields ------ : :py:class:`bytes` or :py:class:`str` or :py:class:`SubstrateUnderrunError` Read data or :py:class:`~pyasn1.error.SubstrateUnderrunError` object if no `size` bytes is readily available in the stream. The data type depends on Python major version Raises ------ : :py:class:`~pyasn1.error.EndOfStreamError` Input stream is exhausted N)contextr)rrSubstrateUnderrunErrorEndOfStreamErrorrrrr)rIrTrYrOs rrSrSs: >>$'  ..w? ?dai((9 9 ]T ! NNCM>2;; 7..w? ? ! $ NsB&B(r7)r%N) r rpyasn1r pyasn1.typerIOBaserrJrPrWrSr!rrr_s= A"299A"H"*JB!-H/r