+
    ~jV                        ^ RI Ht ^ RIt^ RIHt ^ RIHt ^RIHt ^RI	H
t
HtHtHt ^RIHtHt ^RIHtHtHtHtHt ]! ^ ]
P.                  R	7      t ! R
 R]4      t ! R R]4      tR# )    )annotationsN)AsyncIterable)Any)utils)DEFAULT_API_CONNECT_OPTIONS	NOT_GIVENAPIConnectOptions
NotGivenOr)VADVADEventType)STTRecognizeStreamSpeechEventSpeechEventTypeSTTCapabilities)	max_retrytimeoutc                     a  ] tR t^tR V 3R llt]R R l4       t]R R l4       t]R R l4       tR	]	R
]
/R R lltR	]	R
]
/R R lltR R ltR R ltRtV ;t# )StreamAdapterc               $    V ^8  d   QhRRRRRR/# )   sttr   vadr   returnNone )formats   "v/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/stt/stream_adapter.py__annotate__StreamAdapter.__annotate__   s&     F Fs F F F    c               	   < \         SV `  \        R RRR7      R7       W n        Wn        V P                  P                  RV P                  4       R# )TF)	streaminginterim_resultsdiarization)capabilitiesmetrics_collectedN)super__init__r   _vad_stton_on_metrics_collected)selfr   r   	__class__s   &$$r   r)   StreamAdapter.__init__   sM    ( %! 	 	
 		 			($*D*DEr!   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r    "   s      S r!   c                	    V P                   # N)r+   r.   s   &r   wrapped_sttStreamAdapter.wrapped_stt!   s    yyr!   c                   V ^8  d   QhRR/# r   r   strr   )r   s   "r   r   r    &   s      s r!   c                	.    V P                   P                  # r3   )r+   modelr4   s   &r   r;   StreamAdapter.model%   s    yyr!   c                   V ^8  d   QhRR/# r8   r   )r   s   "r   r   r    *   s     " "# "r!   c                	.    V P                   P                  # r3   )r+   providerr4   s   &r   r?   StreamAdapter.provider)   s    yy!!!r!   languageconn_optionsc               (    V ^8  d   QhRRRRRRRR/# )	r   bufferzutils.AudioBufferrA   NotGivenOr[str]rB   r	   r   r   r   )r   s   "r   r   r    -   s2     	
 	
!	
 "		

 (	
 
	
r!   c               	X   "   V P                   P                  WVR 7      G Rj  xL
 #  L5i)rD   rA   rB   N)r+   	recognize)r.   rD   rA   rB   s   &&$$r   _recognize_implStreamAdapter._recognize_impl-   s2      YY((< ) 
 
 	
 
s   !*(*c               $    V ^8  d   QhRRRRRR/# )r   rA   rE   rB   r	   r   r   r   )r   s   "r   r   r    8   s*     
 
 "
 (	

 

r!   c               	J    \        V V P                  V P                  VVR 7      # ))r   r5   rA   rB   )StreamAdapterWrapperr*   r+   )r.   rA   rB   s   &$$r   streamStreamAdapter.stream8   s(     $				%
 	
r!   c               $    V ^8  d   QhRRRRRR/# )r   argsr   kwargsr   r   r   )r   s   "r   r   r    F   s!     8 83 8# 8$ 8r!   c                	2    V P                   ! R .VO5/ VB  R# r'   N)emit)r.   rQ   rR   s   &*,r   r-   #StreamAdapter._on_metrics_collectedF   s    		%777r!   c                   V ^8  d   QhRR/# r   r   r   r   )r   s   "r   r   r    I   s     G Gd Gr!   c                	Z   "   V P                   P                  R V P                  4       R# 5irT   )r+   offr-   r4   s   &r   acloseStreamAdapter.acloseI   s     		)4+E+EFs   )+)r+   r*   )__name__
__module____qualname____firstlineno__r)   propertyr5   r;   r?   r   r   rI   rN   r-   r[   __static_attributes____classcell__r/   s   @r   r   r      s    F F     " "	
 %.		

 +F	

 %.
 +F	
8G Gr!   r   c                  F   a  ] tR t^MtR V 3R lltR R ltR R ltRtV ;t# )rM   c               0    V ^8  d   QhRRRRRRRRRR	R
R/# )r   r   r   r   r   r5   rA   rE   rB   r	   r   r   r   )r   s   "r   r   !StreamAdapterWrapper.__annotate__N   sF     " "" 	"
 " "" (" 
"r!   c               	b   < \         SV `  V\        R 7       W n        W0n        WPn        W@n        R# ))r   rB   N)r(   r)   *DEFAULT_STREAM_ADAPTER_API_CONNECT_OPTIONSr*   _wrapped_stt_wrapped_stt_conn_options	_language)r.   r   r   r5   rA   rB   r/   s   &&$$$$r   r)   StreamAdapterWrapper.__init__N   s.     	S/YZ	')5&!r!   c                    V ^8  d   QhRRRR/# )r   event_aiterzAsyncIterable[SpeechEvent]r   r   r   )r   s   "r   r   rg   ]   s      7Q VZ r!   c                	0   "   V  R j  xL
  pK   LDR # 5ir3   r   )r.   ro   _s   && r   _metrics_monitor_task*StreamAdapterWrapper._metrics_monitor_task]   s     " 	 	!	{s   c                   V ^8  d   QhRR/# rX   r   )r   s   "r   r   rg   a   s     4& 4&D 4&r!   c                	.  a a"   S P                   P                  4       oR  V V3R llpR V V3R llp\        P                  ! V! 4       RR7      \        P                  ! V! 4       RR7      .p \        P                  ! V!  G Rj  xL
  \
        P                  P                  ! V!  G Rj  xL
  SP                  4       G Rj  xL
  R#  LD L  L
  \
        P                  P                  ! T!  G Rj  xL 
  SP                  4       G Rj  xL 
  i ; i5i)c                   V ^8  d   QhRR/# rX   r   )r   s   "r   r   /StreamAdapterWrapper._run.<locals>.__annotate__d   s     	# 	#d 	#r!   c                    <"   SP                     Rj  xL
  p \        V SP                  4      '       d   SP                  4        K8  SP	                  V 4       KK   LFDGSP                  4        R# 5i)zforward input to vadN)	_input_ch
isinstance_FlushSentinelflush
push_frame	end_input)inputr.   
vad_streams    r   _forward_input1StreamAdapterWrapper._run.<locals>._forward_inputd   s^     #~~ - -eeT%8%899$$&%%e,	-~   "s&   A0AAAAA0AA0c                   V ^8  d   QhRR/# rX   r   )r   s   "r   r   rw   n   s     	 	$ 	r!   c                 P  <"   S  Rj  xL
  p V P                   \        P                  8X  d5   SP                  P	                  \        \        P                  4      4       K]  V P                   \        P                  8X  g   K~  SP                  P	                  \        \        P                  R7      4       \        P                  ! V P                  4      pSP                  P                  VSP                  SP                  R7      G Rj  xL
 p\        VP                   4      ^ 8X  d   EK(  VP                   ^ ,          P"                  '       g   EKN  SP                  P	                  \        \        P$                  VP                   ^ ,          .R7      4       EK   EL LEDR# 5i)zrecognize speech from vadN)typerG   )r   alternatives)r   r   START_OF_SPEECH	_event_chsend_nowaitr   r   END_OF_SPEECHr   merge_framesframesrj   rH   rl   rk   lenr   textFINAL_TRANSCRIPT)eventmerged_framest_eventr.   r   s      r   
_recognize-StreamAdapterWrapper._run.<locals>._recognizen   s8    )  e::!=!==NN..{?;Z;Z/[\ZZ<#=#==NN..#!0!>!> %*$6$6u||$DM$($5$5$?$?,!%%)%C%C %@ % G 7//0A5 $11!4999 NN..#!0!A!A*1*>*>q*A)B-  *sG   F&F"FF"A1F&BF&F AF&AF&F" F&"F&forward_input)namerH   N)	r*   rN   asynciocreate_taskgatherr   aiocancel_and_waitr[   )r.   r   r   tasksr   s   f   @r   _runStreamAdapterWrapper._runa   s     YY%%'
	# 	#	 	@  0G
;?
	&..%((())++U333##%%% )3% ))++U333##%%%sl   A)D.C C
C 
!D+C,DCD
C DD"D2C53DDDD)rl   r*   rj   rk   )	r]   r^   r_   r`   r)   rr   r   rb   rc   rd   s   @r   rM   rM   M   s    " "4& 4&r!   rM   )
__future__r   r   collections.abcr   typingr    r   typesr   r   r	   r
   r   r   r   r   r   r   r   r   r   r   ri   r   rM   r   r!   r   <module>r      sY    "  )   Y Y # T T .?4<<. *
8GC 8GvH&? H&r!   