+
     ]iG  c                  s    ^ RI Ht ^ RIt^ RIt^ RIHt RR.tRR R lltRR R	 lltR
 R lt	RR R lls
RR R lltRR R lltR# )    )annotationsN)partialwait_for_readwait_for_writec          
     ,    V ^8  d   QhRRRRRRRRRR/# 	   socksocket.socketreadboolwritetimeoutfloat | Nonereturn Zformat   "6/usr/lib/python3.14/site-packages/urllib3/util/wait.py__annotate__r   !   s:     , ,
,
, , 	,
 
,    c                s.   V'       g   V'       g   \        R 4      h. p. pV'       d   VP                  V 4       V'       d   VP                  V 4       \        \        P                  WEV4      pV! V4      w  rxp	\	        T;'       g    T;'       g    T	4      # )2must specify at least one of read=True, write=True)RuntimeErrorZappendr   selectr   )
r   r
   r   r   ZrcheckZwcheckZfnZrreadyZwreadyZxreadys
   &&&&      r   select_wait_for_socketr   !   sz     OPPFFdd 
	7B[FF**&**F++r   c          
     r   r   r   r   r   r   r   r   9   s:     " "
"
" " 	"
 
"r   c                s:  a V'       g   V'       g   \        R 4      h^ pV'       d   V\        P                  ,          pV'       d   V\        P                  ,          p\        P                  ! 4       oSP                  W4       R V3R llp\        V! V4      4      # )r   c               s     V ^8  d   QhRRRR/# )r   tr   r   zlist[tuple[int, int]]r   r   r   r   r   Z*poll_wait_for_socket.<locals>.__annotate__J   s        <  $9  r   c                s@   < V e
   V R,          p SP                  V 4      # )Ni  )poll)r   poll_objs   &r   do_pollZ%poll_wait_for_socket.<locals>.do_pollJ   s     =IA}}Qr   )r   r   ZPOLLINZPOLLOUTr   Zregisterr   )r   r
   r   r   Zmaskr   r   s   &&&&  @r   poll_wait_for_socketr   9   sr     OPPD{{}Hd!   
  !!r   c               s    V ^8  d   QhRR/# )r   r   r   r   r   r   r   r   r   R   s     
 
D 
r   c                 s     \         P                  ! 4       p V P                  ^ 4       R#   \        \        3 d     R# i ; i)r    TF)r   r   ZAttributeErrorZOSError)r   s    r   _have_working_pollr   R   s<    ;;=a  G$ s   &* ??c          
     r   r   r   r   r   r   r   r   _   s:     7 7
7
7 7 	7
 
7r   c                s    \        4       '       d   \        sM\        \        R 4      '       d   \
        s\        WW#4      # )r   )r   r   wait_for_socketZhasattrr   r   )r   r
   r   r   s   &&&&r   r    r    _   s1     .		"	"04u66r   c               $    V ^8  d   QhRRRRRR/# r   r   r	   r   r   r   r   r   r   r   r   r   r   q   s!     = = = = =r   c                    \        V RVR7      # )z~Waits for reading to be available on a given socket.
Returns True if the socket is readable, or False if the timeout expired.
T)r
   r   r    r   r      &&r   r   r   q   s     4dG<<r   c               r!   r"   r   r   r   r   r   r   x   s!     > > > > >r   c                r#   )z~Waits for writing to be available on a given socket.
Returns True if the socket is readable, or False if the timeout expired.
T)r   r   r$   r%   r&   r   r   r   x   s     4tW==r   )FFN)N)Z
__future__r   r   ZsocketZ	functoolsr   Z__all__r   r   r   r    r   r   r   r   r   <module>r'      s?    "   ,
-4,0"2
7$=> >r   