+
    ~j                        ^ RI Ht ^ RIt^ RIHt ^ RIHtHt ^RIH	t	H
t
 ^RIHtHtHtHt ^RIHt ^RIHtHtHtHtHtHt ]! ^ ]P2                  R	7      t ! R
 R]4      t ! R R]4      tR# )    )annotationsN)AsyncIterable)AnyClassVar)tokenizeutils)DEFAULT_API_CONNECT_OPTIONS	NOT_GIVENAPIConnectOptions
NotGivenOr)SentenceStreamPacer)TTSAudioEmitterChunkedStreamSynthesizedAudioSynthesizeStreamTTSCapabilities)	max_retrytimeoutc                     a  ] tR t^tR]RR/R V 3R lllt]R R l4       t]R R	 l4       tR
]	/R R llt
R
]	/R R lltR R ltR R ltR R ltRtV ;t# )StreamAdaptersentence_tokenizertext_pacingFc               (    V ^8  d   QhRRRRRRRR/# )	   ttsr   r   z&NotGivenOr[tokenize.SentenceTokenizer]r   zSentenceStreamPacer | boolreturnNone )formats   "v/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/tts/stream_adapter.py__annotate__StreamAdapter.__annotate__   s;     N N N C	N
 0N 
N    c               	  < \         SV `  \        R R R7      VP                  VP                  R7       Wn        T;'       g!    \        P                  P                  R R7      V n	        RV n
        VR J d   \        4       V n
        M\        V\        4      '       d   W0n
        V P
                  P                  RV P                  4       R# )T)	streamingaligned_transcript)capabilitiessample_ratenum_channels)retain_formatNmetrics_collected)super__init__r   r)   r*   _wrapped_ttsr   	blingfireSentenceTokenizer_sentence_tokenizer_stream_pacerr   
isinstanceon_on_metrics_collected)selfr   r   r   	__class__s   &$$$r!   r.   StreamAdapter.__init__   s     	(4DQ)) 	 	

  #5 $
 $
9K9K9]9] :^ :
  :>$!4!6D%899!,0$2L2LMr$   c                   V ^8  d   QhRR/# r   r   strr   )r    s   "r!   r"   r#   3   s     ' 's 'r$   c                	.    V P                   P                  # N)r/   modelr7   s   &r!   r?   StreamAdapter.model2   s      &&&r$   c                   V ^8  d   QhRR/# r;   r   )r    s   "r!   r"   r#   7   s     * *# *r$   c                	.    V P                   P                  # r>   )r/   providerr@   s   &r!   rD   StreamAdapter.provider6   s      )))r$   conn_optionsc               $    V ^8  d   QhRRRRRR/# )r   textr<   rF   r   r   r   r   )r    s   "r!   r"   r#   :   s)     R RR*;R	Rr$   c               	:    V P                   P                  WR 7      # ))rH   rF   )r/   
synthesize)r7   rH   rF   s   &&$r!   rJ   StreamAdapter.synthesize:   s       +++QQr$   c                    V ^8  d   QhRRRR/# )r   rF   r   r   StreamAdapterWrapperr   )r    s   "r!   r"   r#   ?   s      I I0I	Ir$   c               	    \        WR 7      # )r   rF   )rM   )r7   rF   s   &$r!   streamStreamAdapter.stream?   s     $HHr$   c                   V ^8  d   QhRR/# r   r   r   r   )r    s   "r!   r"   r#   D   s     $ $ $r$   c                	:    V P                   P                  4        R # r>   )r/   prewarmr@   s   &r!   rU   StreamAdapter.prewarmD   s    !!#r$   c               $    V ^8  d   QhRRRRRR/# )r   argsr   kwargsr   r   r   )r    s   "r!   r"   r#   G   s!     8 83 8# 8$ 8r$   c                	2    V P                   ! R .VO5/ VB  R# r,   N)emit)r7   rX   rY   s   &*,r!   r6   #StreamAdapter._on_metrics_collectedG   s    		%777r$   c                   V ^8  d   QhRR/# rS   r   )r    s   "r!   r"   r#   J   s     O Od Or$   c                	Z   "   V P                   P                  R V P                  4       R# 5ir[   )r/   offr6   r@   s   &r!   acloseStreamAdapter.acloseJ   s"     143M3MNs   )+)r2   r3   r/   )__name__
__module____qualname____firstlineno__r
   r.   propertyr?   rD   r	   rJ   rP   rU   r6   ra   __static_attributes____classcell__r8   s   @r!   r   r      s    N FO	N
 38N N0 ' ' * *R>YR
I3NI
$8O Or$   r   c                  V   a  ] tR t^Nt$ RtR]R&   R V 3R lltR R ltR R	 ltR
t	V ;t
# )rM   tts_stream_adapterzClassVar[str]_tts_request_span_namec               $    V ^8  d   QhRRRRRR/# )r   r   r   rF   r   r   r   r   )r    s   "r!   r"   !StreamAdapterWrapper.__annotate__Q   s#     6 6} 6<M 6RV 6r$   c               	J   < \         SV `  V\        R 7       Wn        W n        R# )rO   N)r-   r.   *DEFAULT_STREAM_ADAPTER_API_CONNECT_OPTIONS_tts_wrapped_tts_conn_options)r7   r   rF   r8   s   &$$r!   r.   StreamAdapterWrapper.__init__Q   s!    S/YZ#&	)5&r$   c                    V ^8  d   QhRRRR/# )r   event_aiterzAsyncIterable[SynthesizedAudio]r   r   r   )r    s   "r!   r"   ro   V   s      7V [_ r$   c                	   "   R # 5ir>   r   )r7   rv   s   &&r!   _metrics_monitor_task*StreamAdapterWrapper._metrics_monitor_taskV   s     s   c                    V ^8  d   QhRRRR/# )r   output_emitterr   r   r   r   )r    s   "r!   r"   ro   Y   s     :4 :4 :4$ :4r$   c                	  a aa"   S P                   P                  P                  4       oS P                   P                  '       d(   S P                   P                  P	                  SSR 7      o\
        P                  ! 4       pSP                  VS P                   P                  S P                   P                  RRR7       \
        P                  ! 4       pSP                  VR7       R V V3R llpR VV V3R llp\        P                  ! V! 4       4      \        P                  ! V! 4       4      .p \        P                  ! V!  G R	j  xL
  SP                  4       G R	j  xL
  \
        P                  P                   ! V!  G R	j  xL
  R	#  LD L. L
  SP                  4       G R	j  xL 
  \
        P                  P                   ! T!  G R	j  xL 
  i ; i5i)
)sent_streamaudio_emitterz	audio/pcmT)
request_idr)   r*   	mime_typerP   )
segment_idc                   V ^8  d   QhRR/# rS   r   )r    s   "r!   r"   /StreamAdapterWrapper._run.<locals>.__annotate__m   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r>   )	_input_chr4   _FlushSentinelflush	push_text	end_input)datar7   r}   s    r!   _forward_input1StreamAdapterWrapper._run.<locals>._forward_inputm   s^     "nn , ,ddD$7$788%%'%%d+,n !!#s&   A0AAAAA0AA0c                   V ^8  d   QhRR/# rS   r   )r    s   "r!   r"   r   w   s     	+ 	+4 	+r$   c            	       <"   ^RI Hp  RpS  Rj  xL
  pSP                  V ! VP                  VR7      4       VP                  P	                  4       ;p'       g   KQ  SP
                  P                  P                  VSP                  R7      ;_uu_4       GRj  xL
 pV  Rj  xL
  pSP                  VP                  P                  P                  4       4       WP                  P                  ,          pK[   L Lc LZD[SP                  4        RRR4      GRj  xL 
  EK    + GRj  xL 
 '       g   i     EK6  ; iED4R# 5i)r   )TimedStringg        N)rH   
start_time)rF   )voice.ior   push_timed_transcripttokenstriprr   r/   rJ   rs   pushframer   tobytesdurationr   )	r   r   evrH   
tts_streamaudior{   r7   r}   s	         r!   _synthesize.StreamAdapterWrapper._run.<locals>._synthesizew   s    .H' + +b44RXX(C !# 0009911<<t'E'E =   '1 9 9e&++EKK,<,<,D,D,FG KK$8$88+9z #((*      (s   EEC>EBED 
E D)#D'D(D+AD)>E EDD)E D#!E)E/D20
E;E=EN)rr   r2   rP   r3   wrapr   	shortuuid
initializer)   r*   start_segmentasynciocreate_taskgatherra   aiocancel_and_wait)r7   r{   r   r   r   r   tasksr}   s   ff     @r!   _runStreamAdapterWrapper._runY   sm    ii33::<99"""))1166', 7 K
 __&
!!!		--//! 	" 	
 __&
$$
$;	$ 	$	+ 	+*  01.
	4..%((($$&&&))++U333 )&3 $$&&&))++U333sl   D-G3F 
FF G"F#%GF	GF GGG)F,*&GGGG)rr   rs   )rc   rd   re   rf   rm   __annotations__r.   rx   r   rh   ri   rj   s   @r!   rM   rM   N   s'    ,@M@6 6
:4 :4r$   rM   )
__future__r   r   collections.abcr   typingr   r    r   r   typesr	   r
   r   r   stream_pacerr   r   r   r   r   r   r   r   r   rq   r   rM   r   r$   r!   <module>r      s^    "  )    Y Y -  .?4<<. *
2OC 2OjE4+ E4r$   