ó ·Úiãó$•SrSSKr"SS5rg)zt Async version of gunicorn/http/unreader.py for ASGI workers. Provides async reading with pushback buffer support. éNcóP•\rSrSrSrS SjrSrSrSrSSjr S r S r S r S r g)Ú AsyncUnreaderéa$Async socket reader with pushback buffer support. This class wraps an asyncio StreamReader and provides the ability to "unread" data back into a buffer for re-parsing. Performance optimization: Reuses BytesIO buffer with truncate/seek instead of creating new objects to reduce GC pressure. có^•Xl[R"5UlX lSUlg)z}Initialize the async unreader. Args: reader: asyncio.StreamReader instance max_chunk: Maximum bytes to read at once rN)ÚreaderÚioÚBytesIOÚbufÚ max_chunkÚ _buf_start)Úselfrr s ÚH/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/asgi/unreader.pyÚ__init__ÚAsyncUnreader.__init__s"€ðŒ Ü—:’:“<ˆŒØ"ŒØˆócó~•URRS5 URRS5 SUlg)z7Reset buffer for reuse instead of creating new BytesIO.rN)r ÚseekÚtruncater ©r s rÚ _reset_bufferÚAsyncUnreader._reset_buffer$s+€à ‰ ‰ aÔØ ‰×ј!Ô؈rcó¤•URRUR5 URR5nUR 5 U$)z'Get all buffered data and reset buffer.)r rr Úreadr)r Údatas rÚ_get_buffered_dataÚ AsyncUnreader._get_buffered_data*s6€à ‰ ‰ d—o‘oÔ&Øx‰x}‰}‹ˆØ ×ÑÔ؈ rcór•URRS[R5nXR- $)zGet size of buffered data.r)r rrÚSEEK_ENDr )r Úends rÚ _buffer_sizeÚAsyncUnreader._buffer_size1s'€àh‰hm‰m˜AœrŸ{™{Ó+ˆØ—_‘_Ñ$Ð$rNcƒóŽ# •Ub [U[5(d [S5eUbUS:XagUS:aSnUR5nUcUS:”aUR 5$UcUR 5IShv•N nU$X!:a‰UR 5IShv•N nU(dUR 5$UR RS[R5 UR RU5 U[U5- nX!:aM‰UR RUR5 UR RU5nU=RU- sl URS:”aLUR R5nUR5 U(aUR RU5 U$GNHGN,7f)zÛRead data from the stream, using buffered data first. Args: size: Number of bytes to read. If None, returns all buffered data or reads a single chunk. Returns: bytes: Data read from buffer or stream Nz&size parameter must be an int or long.rré )Ú isinstanceÚintÚ TypeErrorr rÚ _read_chunkr rrrÚwriteÚlenr rr)r ÚsizeÚbuf_sizeÚchunkrÚ remainings rrÚAsyncUnreader.read6sné€ð Ñ ¤J¨t´S×$9Ñ$9ÜÐDÓEÐ Eà Ñ Øq‹yØØa‹xØà×$Ñ$Ó&ˆð ‰<˜H q›LØ×*Ñ*Ó,Ð ,Ø ‰<Ø×*Ñ*Ó,×,ˆE؈Lð‹oØ×*Ñ*Ó,×,ˆEÞØ×.Ñ.Ó0Ð0Ø H‰HM‰M˜!œRŸ[™[Ô )Ø H‰HN‰N˜5Ô !Ø œ˜E› Ñ "ˆHð oð ‰ ‰ d—o‘oÔ&Øx‰x}‰}˜TÓ"ˆð Š˜4Ñð ?‰?˜TÓ !ØŸ™Ÿ ™ ›ˆIØ × Ñ Ô ÞØ—‘—‘˜yÔ)àˆ ò5-ò -ùs,‚A5GÁ7F?Á8GÂGÂA3GÄ B4GÇGcƒóŠ# •URRUR5IShv•N $N![a gf=f7f)z0Read a chunk of data from the underlying stream.Nr)rrr Ú Exceptionrs rr'ÚAsyncUnreader._read_chunkks:é€ð ØŸ™×)Ñ)¨$¯.©.Ó9×9Ð 9Ñ9øÜó Ùð üs/‚A„(3¬1­3°A±3³ A½A¿AÁAcó.•U(aŽURRUR5 URR5nUR 5 URR U5 U(aURR U5 ggg)z•Push data back into the buffer for re-reading. Args: data: bytes to push back Note: This prepends data to the buffer so it will be read first. N)r rr rrr()r rÚexistings rÚunreadÚAsyncUnreader.unreadrse€ö à H‰HM‰M˜$Ÿ/™/Ô *Ø—x‘x—}‘}“ˆHð × Ñ Ô Ø H‰HN‰N˜4Ô ÞØ—‘—‘˜xÕ(ðð rcó(•UR5S:„$)z-Check if there's data in the pushback buffer.r)r rs rÚhas_buffered_dataÚAsyncUnreader.has_buffered_data…s€à× Ñ Ó" QÑ&Ð&r)r r r r)r#)N)Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__rrrr rr'r4r7Ú__static_attributes__©rrrrs0†ñô òò ò%ô 3òjò)õ&'rr)r=rrr?rrÚr@sðñ ó  ÷y'òy'r