+
    Bi)	                     B   ^ RI t ^ RIt^ RIHt R t ! R R] P                  4      t ! R R]P                  4      t	 ! R R	]	]P                  4      t]P                  ! ]! ] R
4      R4       ! R R]	]P                  4      4       t]R8X  d   ]P                   ! 4        R# R# )    N)
functionalc                  D    \         P                  P                  R 4       R # N)asyncioevents_set_event_loop_policy     </usr/lib/python3.14/test/test_asyncio/test_buffered_proto.pytearDownModuler      s    NN))$/r
   c                   8   a  ] tR t^t o R tR tR tR tRtV t	R# )ReceiveStuffProtoc                    Wn         W n        R # r   )cbcon_lost_fut)selfr   r   s   &&&r   __init__ReceiveStuffProto.__init__   s    (r
   c                :    \        ^d4      V n        V P                  # )d   )	bytearraybuffer)r   sizehints   &&r   
get_bufferReceiveStuffProto.get_buffer   s    n{{r
   c                B    V P                  V P                  R V 4       R # r   )r   r   )r   nbytess   &&r   buffer_updated ReceiveStuffProto.buffer_updated   s    GV$%r
   c                ~    Vf   V P                   P                  R 4       R # V P                   P                  V4       R # r   )r   
set_resultset_exception)r   excs   &&r   connection_lost!ReceiveStuffProto.connection_lost   s/    ;((.++C0r
   )r   r   r   N)
__name__
__module____qualname____firstlineno__r   r   r   r$   __static_attributes____classdictcell____classdict__s   @r   r   r      s     )&1 1r
   r   c                   ,   a  ] tR t^t o R tR tRtV tR# )BaseTestBufferedProtocolc                    \         hr   )NotImplementedErrorr   s   &r   new_loop!BaseTestBufferedProtocol.new_loop    s    !!r
   c                  a a R R,          oVV 3R lpV3R lpS P                   P                  \        P                  ! VR^ 4      4      pVP                  ^ ,          P                  4       pS P                   P                  \        P                  ! V! V4      ^4      4       VP                  4        S P                   P                  VP                  4       4       R# )s	   12345678+i   c                    <aaaa"   R oVVV3R loSP                   P                  4       oSP                   P                  ! VV3R l.V O5!  G Rj  xL
 w  opSG Rj  xL
  R#  L L5i)r
   c                 N   < SV ,          oSS8X  d   SP                  R 4       R# R# )   1N)write)bufNOISEdatatrs   &r   on_buf^BaseTestBufferedProtocol.test_buffered_proto_create_connection.<locals>.client.<locals>.on_buf*   s#    5=HHTN !r
   c                     < \        SS 4      # r   )r   )conn_lost_futr>   s   r   <lambda>`BaseTestBufferedProtocol.test_buffered_proto_create_connection.<locals>.client.<locals>.<lambda>3   s    )&-@r
   N)loopcreate_futurecreate_connection)addrprrA   r<   r>   r=   r;   r   s   & @@@@r   clientNBaseTestBufferedProtocol.test_buffered_proto_create_connection.<locals>.client'   se     D# !II335M9966@ICGI IFB  I  s$   AA*A&A*A( A*(A*c                    <"   VP                  S4       V P                  ^4      G Rj  xL
  VP                  4        VP                  4       G Rj  xL
  R#  L. L5i)   N)r9   readexactlyclosewait_closed)readerwriterr;   s   &&r   on_server_clientXBaseTestBufferedProtocol.test_buffered_proto_create_connection.<locals>.on_server_client7   sI     LL$$Q'''LLN$$&&& (&s!   &AA'AAAAz	127.0.0.1N)	rD   run_until_completer   start_serversocketsgetsocknamewait_forrN   rO   )r   rI   rR   srvrG   r;   s   f    @r   %test_buffered_proto_create_connection>BaseTestBufferedProtocol.test_buffered_proto_create_connection#   s    t#	  	' ii**   +q23 {{1~))+		$$VD\1-	/ 					$$S__%67r
   r	   N)r&   r'   r(   r)   r3   rZ   r*   r+   r,   s   @r   r/   r/      s     "#8 #8r
   r/   c                   &   a  ] tR t^It o R tRtV tR# )BufferedProtocolSelectorTestsc                ,    \         P                  ! 4       # r   )r   SelectorEventLoopr2   s   &r   r3   &BufferedProtocolSelectorTests.new_loopL       ((**r
   r	   Nr&   r'   r(   r)   r3   r*   r+   r,   s   @r   r]   r]   I   s     + +r
   r]   ProactorEventLoopzWindows onlyc                   &   a  ] tR t^Pt o R tRtV tR# )BufferedProtocolProactorTestsc                ,    \         P                  ! 4       # r   )r   rc   r2   s   &r   r3   &BufferedProtocolProactorTests.new_loopT   ra   r
   r	   Nrb   r,   s   @r   re   re   P   s     + +r
   re   __main__)r   unittesttest.test_asyncior   
func_testsr   BufferedProtocolr   FunctionalTestCaseMixinr/   TestCaser]   
skipUnlesshasattrre   r&   mainr	   r
   r   <module>rr      s      60100 1&(8zAA (8V+$<$,$5$5+ 
WW&9:NK+$<$,$5$5+ L+ zMMO r
   