AҐiA $dZddlZGddZy)zt Async version of gunicorn/http/unreader.py for ASGI workers. Provides async reading with pushback buffer support. Nc2eZdZdZddZd dZdZdZdZy) AsyncUnreaderzAsync 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. cR||_tj|_||_y)zInitialize the async unreader. Args: reader: asyncio.StreamReader instance max_chunk: Maximum bytes to read at once N)readerioBytesIObuf max_chunk)selfrr s O/var/www/descvideos/venv/lib/python3.12/site-packages/gunicorn/asgi/unreader.py__init__zAsyncUnreader.__init__s ::<"NcK|t|ts td| |dk(ry|dkrd}|jj dt j |O|jjr5|jj}t j|_|S||jd{}|S|jj|kr|jd{}|s5|jj}t j|_|S|jj||jj|kr|jj}t j|_|jj||d|d|S77ͭw)a 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) isinstanceint TypeErrorr seekrSEEK_ENDtellgetvaluer _read_chunkwrite)r sizeretchunkdatas r readzAsyncUnreader.read sg  JtS$9DE E  qyax  a% r+s   VVr