+ j&Rt^RIt!RR4tR#)zt Async version of gunicorn/http/unreader.py for ASGI workers. Provides async reading with pushback buffer support. Nc\a]tRt^toRtR RltRtRtRtR Rlt Rt R t R t R t VtR#) AsyncUnreadera$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 `Wn\P!4VnW n^VnR#)z}Initialize the async unreader. Args: reader: asyncio.StreamReader instance max_chunk: Maximum bytes to read at once N)readerioBytesIObuf max_chunk _buf_start)selfrr s&&&K/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/asgi/unreader.py__init__AsyncUnreader.__init__s" ::<"c VPP^4VPP^4^VnR#)z7Reset buffer for reuse instead of creating new BytesIO.N)rseektruncater r s&r _reset_bufferAsyncUnreader._reset_buffer$s+  a !rc VPPVP4VPP4pVP 4V#)z'Get all buffered data and reset buffer.)rrr readr)r datas& r _get_buffered_data AsyncUnreader._get_buffered_data*s6  doo&xx}}  rc zVPP^\P4pWP, #)zGet size of buffered data.)rrrSEEK_ENDr )r ends& r _buffer_sizeAsyncUnreader._buffer_size1s'hhmmAr{{+__$$rNc "Ve"\V\4'g \R4hVeV^8XdR#V^8dRpVP4pVfV^8dVP 4#VfVP 4GRjxL pV#W!8dVP 4GRjxL pV'gVP 4#VP P^\P4VP PV4V\V4, pKVP PVP4VP PV4pV;PV, un VPR8dNVP P4pVP4V'dVP PV4V#ELOEL25i)zRead 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.r ) isinstanceint TypeErrorrr _read_chunkrrrrwritelenr rr)r sizebuf_sizechunkr remainings&& r rAsyncUnreader.read6sg  JtS$9$9DE E  qyax$$& GGG G! G-DG2GGc "VPPVP4GRjxL #L \dR#i;i5i)z0Read a chunk of data from the underlying stream.Nr)rrr Exceptionrs&r r%AsyncUnreader._read_chunkks: ))$..99 99  s0A(313A3 AAAAc 8V'dVPPVP4VPP4pVP 4VPP V4V'dVPP V4R#R#R#)zPush 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)rrr rrr&)r rexistings&& r unreadAsyncUnreader.unreadrse  HHMM$// *xx}}H    HHNN4 x( rc (VP4^8#)z-Check if there's data in the pushback buffer.)rrs&r has_buffered_dataAsyncUnreader.has_buffered_datas  "Q&&r)r rr r)r!)N)__name__ __module__ __qualname____firstlineno____doc__r rrrrr%r2r5__static_attributes____classdictcell__) __classdict__s@r rrs8  % 3j)&''rr)r;rrrr r@s   y'y'r