+
    i8*  c                   s    Rt  ! R R 4      t ! R R]4      t ! R R]4      t ! R	 R]]4      t ! R
 R]4      t ! R R]4      t ! R R]4      tR# )BaseTransportReadTransportWriteTransport	TransportDatagramTransportSubprocessTransportc                   sP   a  ] tR t^	t o RtR	R ltR	R ltR tR tR t	R t
RtV tR# )
r    Nc                s    Vf   / pWn         R # N_extra)selfextra   &&+/usr/lib64/python3.14/asyncio/transports.py__init__ZBaseTransport.__init__   s    =E    c                s8    V P                   P                  W4      # r   )r   Zget)r	   ZnameZdefault   &&&r   get_extra_infoZBaseTransport.get_extra_info   s    {{t--r   c                    \         hr   ZNotImplementedErrorr	      &r   
is_closingZBaseTransport.is_closing       !!r   c                r   r   r   r   r   r   closeZBaseTransport.close   s
     "!r   c                r   r   r   )r	   protocolr   r   set_protocolZBaseTransport.set_protocol%   r   r   c                r   r   r   r   r   r   get_protocolZBaseTransport.get_protocol)   r   r   r   r   )__name__
__module____qualname____firstlineno__	__slots__r   r   r   r   r   r   __static_attributes____classdictcell____classdict__   @r   r    r    	   s/      I
."""" "r   c                   s6   a  ] tR t^.t o RtR tR tR tRtV t	R# )r   c                r   r   r   r   r   r   
is_readingZReadTransport.is_reading3   r   r   c                r   r   r   r   r   r   pause_readingZReadTransport.pause_reading7   
     "!r   c                r   r   r   r   r   r   resume_readingZReadTransport.resume_reading?   r'   r    N)
r   r   r   r   r   r%   r&   r(   r    r!   r"   r$   r   r   r   .   s       I""" "r   c                   sX   a  ] tR t^Ht o R
tRR ltR tR tR tR t	R t
R tR	 tR
tV tR# )r   Nc                r   r   r   r	   highlowr   r   set_write_buffer_limitsZ&WriteTransport.set_write_buffer_limitsM   s
    & "!r   c                r   r   r   r   r   r   get_write_buffer_sizeZ$WriteTransport.get_write_buffer_sizeb   r   r   c                r   r   r   r   r   r   get_write_buffer_limitsZ&WriteTransport.get_write_buffer_limitsf   s
     "!r   c                r   r   r   )r	   datar   r   writeZWriteTransport.writel   r'   r   c                sJ    R P                  V4      pV P                  V4       R# )r   N)Zjoinr1   )r	   Zlist_of_datar0   s   && r   
writelinesZWriteTransport.writelinest   s     xx%

4r   c                r   r   r   r   r   r   	write_eofZWriteTransport.write_eof}   
     "!r   c                r   r   r   r   r   r   can_write_eofZWriteTransport.can_write_eof   r   r   c                r   r   r   r   r   r   abortZWriteTransport.abort   r4   r   r)   NN)r   r   r   r   r   r-   r.   r/   r1   r2   r3   r5   r6   r    r!   r"   r$   r   r   r   H   s9      I"*"""""" "r   c                   s    ] tR t^tRtRtR# )r   r)   N)r   r   r   r   r   r    r)   r   r   r   r      s	    * Ir   c                   s4   a  ] tR t^t o RtRR ltR tRtV tR# )r   Nc                r   r   r   )r	   r0   Zaddrr   r   sendtoZDatagramTransport.sendto   s
     "!r   c                r   r   r   r   r   r   r6   ZDatagramTransport.abort   r4   r   r)   r   )	r   r   r   r   r   r8   r6   r    r!   r"   r$   r   r   r      s      I
"" "r   c                   sH   a  ] tR t^t o RtR tR tR tR tR t	R t
RtV tR# )	r   c                r   r   r   r   r   r   get_pidZSubprocessTransport.get_pid   r   r   c                r   r   r   r   r   r   get_returncodeZ"SubprocessTransport.get_returncode   r'   r   c                r   r   r   )r	   Zfdr   r   get_pipe_transportZ&SubprocessTransport.get_pipe_transport   r   r   c                r   r   r   )r	   Zsignalr   r   send_signalZSubprocessTransport.send_signal   r'   r   c                r   r   r   r   r   r   	terminateZSubprocessTransport.terminate   s
     "!r   c                r   r   r   r   r   r   killZSubprocessTransport.kill   s
     "!r   r)   N)r   r   r   r   r   r9   r:   r;   r<   r=   r>   r    r!   r"   r$   r   r   r      s-     I"""""	" 	"r   c                   sf   a a ] tR t^t oR	tR
V 3R lltR tR tR tR
R lt	R
R lt
R tRtVtV ;t# )_FlowControlMixinc                s`   < \         SV `  V4       W n        R V n        V P	                  4        R# )FN)Zsuperr   _loop_protocol_paused_set_write_buffer_limits)r	   r
   Zloop	__class__s   &&&r   r   Z_FlowControlMixin.__init__  s)    
 %%%'r   c                sd   V P                  4       pWP                  8:  d   R # V P                  '       g%   RV n         V P                  P	                  4        R # R #   \
        \        3 d    h \         d9   pT P                  P                  RRRTRT RT P                  /4        R p?R # R p?ii ; i)NTmessagezprotocol.pause_writing() failed	exception	transportr   )
r.   _high_waterrA   	_protocolZpause_writing
SystemExitKeyboardInterruptBaseExceptionr@   call_exception_handler)r	   Zsizeexcs   &  r   _maybe_pause_protocolZ'_FlowControlMixin._maybe_pause_protocol  s    ))+###$$$$(D!
,,. %  12   

11@	3  s   A B/6B/7-B**B/c                sb   V P                   '       dF   V P                  4       V P                  8:  d%   R V n          V P                  P	                  4        R# R# R#   \
        \        3 d    h \         d9   pT P                  P                  RRRTRT RT P                  /4        Rp?R# Rp?ii ; i)FrD   z protocol.resume_writing() failedrE   rF   r   N)
rA   r.   
_low_waterrH   Zresume_writingrI   rJ   rK   r@   rL   )r	   rM   s   & r   _maybe_resume_protocolZ(_FlowControlMixin._maybe_resume_protocol)  s    !!!**,?$)D!
--/ @ "
  12   

11A	3  s   A B.5B.6-B))B.c                s2    V P                   V P                  3# r   )rO   rG   r   r   r   r/   Z)_FlowControlMixin.get_write_buffer_limits9  s    !1!122r   c                s    Vf   Vf   RpM	^V,          pVf
   V^,          pYu;8  d   ^ 8  g   M \        RV: RV: R24      hWn        W n        R # )Nzhigh (z) must be >= low (z) must be >= 0i   )Z
ValueErrorrG   rO   r*   r   r   rB   Z*_FlowControlMixin._set_write_buffer_limits<  sb    <{ 3w;!)Ca 23'HJ J  r   c                sJ    V P                  WR 7       V P                  4        R# ))r+   r,   N)rB   rN   r*   r   r   r-   Z)_FlowControlMixin.set_write_buffer_limitsL  s    %%4%9""$r   c                r   r   r   r   r   r   r.   Z'_FlowControlMixin.get_write_buffer_sizeP  s    !!r   )rG   r@   rO   rA   )r@   rA   rG   rO   r7   )r   r   r   r   r   r   rN   rP   r/   rB   r-   r.   r    r!   Z__classcell__)rC   r#   s   @@r   r?   r?      s5     " KI($ 3 %" "r   r?   N)r    r   r   r   r   r   )Z__all__r    r   r   r   r   r   r?   r)   r   r   <module>rQ      sg   "" ""J"M "4I"] I"X~ 0" "63"- 3"lT"	 T"r   