Ë
    /æjå	  ã                  ó¾   — d dl mZ d dlZd dlZd dlZd dlZd dlmZmZm	Z	m
Z
mZ d dlmZmZmZmZ d dlmZ  ej&                  d«      Zd
d„Z	 	 	 	 dd„Zedd	„«       Zy)é    )ÚannotationsN)ÚAsyncIterableÚAsyncIteratorÚ	GeneratorÚIterableÚIterator)ÚAbstractAsyncContextManagerÚaclosingÚcontextmanagerÚnullcontext)ÚAsyncGeneratorTypeÚTc                ón  — | €dn| j                  «       }|�|dk  ryt        j                  dk(  st        t        dd«      €(t	        j                  |gg g d«      \  }}}t        |«      S t	        j                  «       }|j                  |t        j                  «       t        |j                  d«      «      S )zà
    Return whether a socket, as identified by its file descriptor, is readable.
    "A socket is readable" means that the read buffer isn't empty, i.e. that calling
    .recv() on it would immediately return some data.
    Nr   TÚwin32Úpoll)	ÚfilenoÚsysÚplatformÚgetattrÚselectÚboolr   ÚregisterÚPOLLIN)ÚsockÚsock_fdÚrreadyÚ_Úps        úS/root/repos/pocs/video-evals/.venv/lib/python3.12/site-packages/httpcore2/_utils.pyÚis_socket_readabler       s”   € ð �l‰d¨¯©«€GØ€˜' Aš+Øô ‡|�|�wÒ¤'¬&°&¸$Ó"?Ð"GÜ—}‘} g Y°°B¸Ó:‰ˆ��1Ü�F‹|ÐÜ�‰‹€AØ‡J�JˆwœŸ™Ô&Ü�—‘�q“	‹?Ðó    c               ó’   — t        | t        «      r| n| j                  «       }t        |t        «      rt	        |«      S t        |«      S ©N)Ú
isinstancer   Ú	__aiter__r   r
   r   ©Úiterable_or_iteratorÚiterators     r   Úsafe_async_iterater)   2   sF   € ô !+Ð+?ÄÔ OÑÐUi×UsÑUsÓUuð ô �(Ô.Ô/Ü˜Ó!Ð!Ü�xÓ Ð r!   c             #  óX   K  — t        | t        «      r| n| j                  «       }|–— y ­wr#   )r$   r   Ú__iter__r&   s     r   Úsafe_iterater,   =   s)   è ø€ ô (2Ð2FÌÔ'QÑ#ÐWk×WtÑWtÓWv€HØ
ƒNùs   ‚(*)r   zsocket.socket | NoneÚreturnr   )r'   z#AsyncIterable[T] | AsyncIterator[T]r-   z-AbstractAsyncContextManager[AsyncIterator[T]])r'   zIterable[T] | Iterator[T]r-   z"Generator[Iterator[T], None, None])Ú
__future__r   r   Úsocketr   ÚtypingÚcollections.abcr   r   r   r   r   Ú
contextlibr	   r
   r   r   Útypesr   ÚTypeVarr   r    r)   r,   © r!   r   ú<module>r6      sh   ðÝ "ã Û Û 
Û ÷õ ÷ ZÓ YÝ $à€F‡N�N�3Ó€óð<!Ø=ð!à2ó!ð òó ñr!   