(j$SrSSKr"SS5rg)zt Async version of gunicorn/http/unreader.py for ASGI workers. Provides async reading with pushback buffer support. NcP\rSrSrSrS SjrSrSrSrSSjr S r S r S r S r g) 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^Xl[R"5UlX lSUlg)z}Initialize the async unreader. Args: reader: asyncio.StreamReader instance max_chunk: Maximum bytes to read at once rN)readerioBytesIObuf max_chunk _buf_start)selfrr s N/var/www/html/KUNJ/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 seektruncater r s r _reset_bufferAsyncUnreader._reset_buffer$s+  a !rcURRUR5 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  doo&xx}}  rcrURRS[R5nXR- $)zGet size of buffered data.r)r rrSEEK_ENDr )r ends r _buffer_sizeAsyncUnreader._buffer_size1s'hhmmAr{{+__$$rNc# Ub [U[5(d [S5eUbUS:XagUS:aSnUR5nUcUS:aUR 5$UcUR 5IShvN nU$X!:aUR 5IShvN nU(dUR 5$UR RS[R5 UR RU5 U[U5- nX!:aMUR RUR5 UR RU5nU=RU- sl URS:aLUR R5nUR5 U(aUR RU5 U$GNHGN,7f)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.rr ) isinstanceint TypeErrorr r _read_chunkr rrrwritelenr rr)r sizebuf_sizechunkr remainings rrAsyncUnreader.read6sn  JtS$9$9DE E  qyax$$& r@s   y'y'r