+
     Hi  c                   s    R t ^ RIt^ RIt^ RIt^ RIHt ]P                  RR l4       t]P                  RR l4       t ! R R]P                  4      t
R# )	zImplementation of coroutines without using ``async def``/``await`` keywords.

``@asyncio.coroutine`` and ``yield from`` are  used here instead.
N)EOFc              #   s  a"   V P                  4       pVe   V# V P                  P                  '       gn   \        4       oSP	                  V 4       \
        P                  ! 4       P                  V3R lV P                  4       R j  xL
 w  poSV3V P                  n        M:V P                  P                  w  opSP	                  V 4       VP                  4         \
        P                  ! SP                  V4       R j  xL
 #  L L  \
        P                   d,   pTP                  4        T P                  T4      u R p?# R p?ii ; i5i)Nc                  s   < S # N )pws   =/usr/lib/python3.14/site-packages/pexpect/_async_pre_await.pyZ<lambda>Zexpect_async.<locals>.<lambda>   s    B    )Zexisting_dataspawnZasync_pw_transportPatternWaiterset_expecterasyncioZget_event_loopZconnect_read_pipeZresume_readingZwait_forfutZTimeoutErrorpause_readingtimeout)expecterr   Zidx	transporter   s   &&   @r   expect_asyncr      s     
 
 
"C

>>,,,_
!#*#9#9#;#M#M$
 
	2 -/	M) 99I
!  "#"++BFFG<<=
 = #!""#sZ   2EAEDAE$D D	D E	D E  E EEEEc              #   sn  "   . pV P                   P                  V^ ,          4       VR,           F^  pV P                  VRR7       Rj  xL
  VP                  V P                   P                  4       V P                   P                  V4       K`  	  V P                  VRR7       Rj  xL
 pV^8X  dP   V P                   P                  \        P                  4       V P                  ^RR7       Rj  xL
  \        R4      hRP                  W0P                   P                  .,           4      #  L L L?5i)i    :i   NNT)r   Zasync_Nz1Continuation prompt found - input was incomplete:Z )
ZchildZsendlineZ_expect_promptZappendZbeforeZkillsignalZSIGINTZ
ValueErrorZjoin)ZreplZcmdlinesr   ZresZlineZ
prompt_idxs   &&&   r   repl_run_command_asyncr   %   s     
CJJ$&&wt&DDD

4::$$%

D!  !///MMJQ

&&&q&>>>LMM773**++,,-- 	E
 N 	?s8   AD5	D/
AD5(D1)A
D53D34<D51D53D5c                   sN   a  ] tR t^8t o RtR tR tR tR tR t	R t
R tR	tV tR# )
r   Nc                sF    Wn         \        P                  ! 4       V n        R # r   )r   r	   ZFuturer
   )selfr      &&r   r   ZPatternWaiter.set_expecter;   s     >>#r   c                    V P                   P                  4       '       g8   V P                   P                  V4       V P                  P	                  4        R # R # r   )r
   doneZ
set_resultr   r   )r   Zresultr   r   foundZPatternWaiter.found?   s8    xx}}HH'NN((* r   c                r   r   )r
   r   Zset_exceptionr   r   r   Zexcr   r   errorZPatternWaiter.errorD   s8    xx}}HH""3'NN((* r   c                s    Wn         R # r   )r   )r   r   r   r   connection_madeZPatternWaiter.connection_madeI   s    "r   c                s*   V P                   P                  pVP                  P                  V4      pVP	                  VR 4       V P
                  P                  4       '       d9   VP                  P                  V4       VP                  P                  V4       R#  V P                   P                  V4      pVe   V P                  V4       R# R#   \         d7   pT P                   P                  4        T P                  T4        Rp?R# Rp?ii ; i)ZreadN)r   r   Z_decoderZdecodeZ_logr
   r   Z_beforeZwriteZ_bufferZnew_datar   Z	ExceptionZerroredr   )r   Zdatar   Zsindexr   s   &&    r   data_receivedZPatternWaiter.data_receivedL   s    ##NN!!$'

1f88==??MM"MM"	MM**1-E 

5! !  	MM!!#JJqMM	s   0C D+DDc                s     R V P                   P                  n        V P                   P                  4       pV P	                  V4       R#   \
         d   pT P                  T4        Rp?R# Rp?ii ; i)TN)r   r   Zflag_eofZeofr   r    r   )r   r   r   s   &  r   eof_receivedZPatternWaiter.eof_received_   sX    	+/DMM(MM%%'E JJu  	JJqMM	s   5A
 
A1A,,A1c                s    \        V\        4      '       d2   VP                  \        P                  8X  d   V P	                  4        R # Ve   V P                  V4       R # R # r   )Z
isinstanceZOSErrorerrnoZEIOr   r   r   r   r   connection_lostZPatternWaiter.connection_lostj   s?    c7##		UYY(>_JJsO r   )r   r
   r   )Z__name__Z
__module__Z__qualname__Z__firstlineno__r   r   r   r   r   r   r   r   Z__static_attributes__Z__classdictcell__)Z__classdict__s   @r   r   r   8   s2     I$+
+
#&	 r   r   r   )i)Z__doc__r	   r   r   Zpexpectr    Z	coroutiner   r   ZProtocolr   r   r   r   <module>r       s^        	# #0 	. .$7G$$ 7r   