+
    ~j9                       ^ RI Ht ^ RIt^ RIt^ RIHt ^ RIHtHtH	t	H
t
HtHtHtHt ^ RIHtHtHtHtHtHt ^ RIt^RIHtHt ^RIHt ]'       d   ^RIHtHt ^R	IH t  ]
! R
4      t! ! R R]	]!,          4      t" ! R R]	]!,          4      t# ! R R4      t$ ! R R4      t%] ! R R]4      4       t&R R lt'RR/R R llt(R# )    )annotationsN)TracebackType)TYPE_CHECKINGAnyGenericTypeVarIteratorOptionalAsyncIteratorcast)SelfProtocol	TypeGuardoverride
get_originruntime_checkable)
is_mappingextract_type_var_from_base)APIError)OpenAIAsyncOpenAI)FinalRequestOptions_Tc                      ] tR t^t$ RtR]R&   RtR]R&   R]R&   R	R/R
 R lltR R ltR R lt	R R lt
R R ltR R ltR R ltR R ltRtR# )StreamzJProvides the core interface to iterate over a synchronous stream response.httpx.ResponseresponseNOptional[FinalRequestOptions]_optionsSSEBytesDecoder_decoderoptionsc          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )   cast_totype[_T]r   r   clientr   r"   r   returnNone )formats   "f/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/openai/_streaming.py__annotate__Stream.__annotate__   s>     + + + !	+
 + /+ 
+    c               	    W n         Wn        W0n        W@n        VP	                  4       V n        V P                  4       V n        R # Nr   _cast_to_clientr   _make_sse_decoderr!   
__stream__	_iteratorselfr%   r   r'   r"   s   &$$$$r,   __init__Stream.__init__   6     !002*r/   c                   V ^8  d   QhRR/# r$   r(   r   r*   )r+   s   "r,   r-   r.   -   s     ) )" )r/   c                	6    V P                   P                  4       # r1   )r7   __next__r9   s   &r,   r@   Stream.__next__-   s    ~~&&((r/   c                   V ^8  d   QhRR/# r$   r(   zIterator[_T]r*   )r+   s   "r,   r-   r.   0   s      , r/   c              #  	<   "   V P                    F  pVx  K	  	  R # 5ir1   r7   r9   items   & r,   __iter__Stream.__iter__0   s     NNDJ #s   c                   V ^8  d   QhRR/# )r$   r(   Iterator[ServerSentEvent]r*   )r+   s   "r,   r-   r.   4   s     H H7 Hr/   c              #  	   "   V P                   P                  V P                  P                  4       4       R j  xL
  R #  L5ir1   )r!   
iter_bytesr   rA   s   &r,   _iter_eventsStream._iter_events4   s*     ==++DMM,D,D,FGGGs   7AA Ac                   V ^8  d   QhRR/# rD   r*   )r+   s   "r,   r-   r.   7   s     7 7L 7r/   c              #  	z  "   \        \        V P                  4      pV P                  pV P                  P
                  pV P                  4       p V EF=  pVP                  P                  R 4      '       d    EMVP                  '       Ed   VP                  P                  R4      '       d   VP                  4       pVP                  R8X  d   \        V4      '       d   VP                  R4      '       d   RpVP                  R4      p\        V4      '       d   VP                  R4      pV'       d   \        V\        4      '       g   Rp\        VV P                  P                   VR,          R7      hV! RVRVP                  /WR	7      x  EK@  VP                  4       p\        V4      '       d   VP                  R4      '       d   RpVP                  R4      p\        V4      '       d   VP                  R4      pV'       d   \        V\        4      '       g   Rp\        VV P                  P                   VR,          R7      hT! V P"                  e-   V P"                  P$                  '       d   RVRVP                  /MTVVR	7      x  EK@  	  VP'                  4        R#   TP'                  4        i ; i5i)
[DONE]thread.errorNmessage"An error occurred during streamingrV   requestbodydataeventr[   r%   r   )r   r   r3   r   r4   _process_response_datarO   r[   
startswithr\   jsonr   get
isinstancestrr   rY   r   synthesize_event_and_dataclose	r9   r%   r   process_dataiteratorsser[   rV   rU   s	   &        r,   r6   Stream.__stream__7   s    sDMM*==||::$$&1	88&&x00 999!5!5i!@!@88:DyyG+
40@0@TXXgEVEV"& $ 1%e,,&+ii	&:G&j#.F.F&JG&$+$(MM$9$9!%g  'VT7CII,NX_ss88:D!$''DHHW,=,="& $ 1%e,,&+ii	&:G&j#.F.F&JG&$+$(MM$9$9!%g  '==49`9`9` %dGSYY?! '!) O  ` NNHNNsK   AJ;<J&  J& .AJ& 7<J& 4BJ& 
<J& A,J& 4 J& J;&J88J;c                   V ^8  d   QhRR/# r$   r(   r   r*   )r+   s   "r,   r-   r.   p   s      4 r/   c                	    V # r1   r*   rA   s   &r,   	__enter__Stream.__enter__p   s    r/   c               (    V ^8  d   QhRRRRRRRR/# 	r$   exc_typeztype[BaseException] | NoneexczBaseException | Noneexc_tbzTracebackType | Noner(   r)   r*   )r+   s   "r,   r-   r.   s   s2      , " %	
 
r/   c                	&    V P                  4        R # r1   re   r9   rr   rs   rt   s   &&&&r,   __exit__Stream.__exit__s   s     	

r/   c                   V ^8  d   QhRR/# r$   r(   r)   r*   )r+   s   "r,   r-   r.   {   s      t r/   c                :    V P                   P                  4        R# zr
Close the response and release the connection.

Automatically called if the response body is read to completion.
N)r   re   rA   s   &r,   re   Stream.close{   s     	r/   r3   r4   r!   r7   r   r   )__name__
__module____qualname____firstlineno____doc____annotations__r   r:   r@   rI   rO   r6   rn   rx   re   __static_attributes__r*   r/   r,   r   r      sU    T.2H+2+ 26+)H7r r/   r   c                      ] tR t^t$ RtR]R&   RtR]R&   R]R&   R	R/R
 R lltR R ltR R lt	R R lt
R R ltR R ltR R ltR R ltRtR# )AsyncStreamzLProvides the core interface to iterate over an asynchronous stream response.r   r   Nr   r   zSSEDecoder | SSEBytesDecoderr!   r"   c          
     ,    V ^8  d   QhRRRRRRRRR	R
/# )r$   r%   r&   r   r   r'   r   r"   r   r(   r)   r*   )r+   s   "r,   r-   AsyncStream.__annotate__   s>     + + + !	+
 + /+ 
+r/   c               	    W n         Wn        W0n        W@n        VP	                  4       V n        V P                  4       V n        R # r1   r2   r8   s   &$$$$r,   r:   AsyncStream.__init__   r<   r/   c                   V ^8  d   QhRR/# r>   r*   )r+   s   "r,   r-   r      s     0 0 0r/   c                	R   "   V P                   P                  4       G R j  xL
 #  L5ir1   )r7   	__anext__rA   s   &r,   r   AsyncStream.__anext__   s     ^^--////s   '%'c                   V ^8  d   QhRR/# r$   r(   zAsyncIterator[_T]r*   )r+   s   "r,   r-   r      s      !2 r/   c               	N   "   V P                     R j  xL
  pV5x  K   LDR # 5ir1   rF   rG   s   & r,   	__aiter__AsyncStream.__aiter__   s$     .. 	 	$J	.s   %" "	%"%c                   V ^8  d   QhRR/# )r$   r(   AsyncIterator[ServerSentEvent]r*   )r+   s   "r,   r-   r      s      $B r/   c               	   "   V P                   P                  V P                  P                  4       4        R j  xL
  pV5x  K   LDR # 5ir1   )r!   aiter_bytesr   )r9   ri   s   & r,   rO   AsyncStream._iter_events   s=     224==3L3L3NO 	 	#I	Os%   4AA	AA		AA		Ac                   V ^8  d   QhRR/# r   r*   )r+   s   "r,   r-   r      s     7$ 7$"3 7$r/   c               	  "   \        \        V P                  4      pV P                  pV P                  P
                  pV P                  4       p V  R j  xL
  pVP                  P                  R4      '       d    EMVP                  '       Ed   VP                  P                  R4      '       d   VP                  4       pVP                  R8X  d   \        V4      '       d   VP                  R4      '       d   R pVP                  R4      p\        V4      '       d   VP                  R4      pV'       d   \        V\        4      '       g   Rp\        VV P                  P                   VR,          R7      hV! RVRVP                  /WR	7      5x  EKG  VP                  4       p\        V4      '       d   VP                  R4      '       d   R pVP                  R4      p\        V4      '       d   VP                  R4      pV'       d   \        V\        4      '       g   Rp\        VV P                  P                   VR,          R7      hT! V P"                  e-   V P"                  P$                  '       d   RVRVP                  /MTVVR	7      5x  EKH  VP'                  4       G R j  xL
  R #  EL^ED`L  L  TP'                  4       G R j  xL 
  i ; i5i)
NrS   rT   rU   rV   rW   rX   r[   r\   r]   )r   r   r3   r   r4   r^   rO   r[   r_   r\   r`   r   ra   rb   rc   r   rY   r   rd   acloserf   s	   &        r,   r6   AsyncStream.__stream__   s1    sDMM*==||::$$&1	$% - -c88&&x00 999!5!5i!@!@88:DyyG+
40@0@TXXgEVEV"& $ 1%e,,&+ii	&:G&j#.F.F&JG&$+$(MM$9$9!%g  'VT7CII,NX_ss88:D!$''DHHW,=,="& $ 1%e,,&+ii	&:G&j#.F.F&JG&$+$(MM$9$9!%g  '==49`9`9` %dGSYY?! '!)  //###a-X` $(//###s   AKJ< J7J4J78J<  J< 4AJ< =<J< :BJ< <J< A,J< ;J< K-J:.K4J77J< :K<KKKKc                   V ^8  d   QhRR/# rl   r*   )r+   s   "r,   r-   r      s      $ r/   c                	   "   V # 5ir1   r*   rA   s   &r,   
__aenter__AsyncStream.__aenter__   s
     s   c               (    V ^8  d   QhRRRRRRRR/# rq   r*   )r+   s   "r,   r-   r      s2      , " %	
 
r/   c                	B   "   V P                  4       G R j  xL
  R #  L5ir1   rv   rw   s   &&&&r,   	__aexit__AsyncStream.__aexit__   s      jjls   c                   V ^8  d   QhRR/# r{   r*   )r+   s   "r,   r-   r      s     % %T %r/   c                V   "   V P                   P                  4       G Rj  xL
  R#  L5ir}   )r   r   rA   s   &r,   re   AsyncStream.close   s      mm""$$$s   )')r   )r   r   r   r   r   r   r   r:   r   r   rO   r6   r   r   re   r   r*   r/   r,   r   r      sT    V.2H+2**+ 26+07$r% %r/   r   c                      ] tR t^tRRRRRRRR/R R llt]R R	 l4       t]R
 R l4       t]R R l4       t]R R l4       t	R R lt
]R R l4       tRtR# )ServerSentEventr\   Nr[   idretryc          
     ,    V ^8  d   QhRRRRRRRRRR/# )	r$   r\   
str | Noner[   r   r   
int | Noner(   r)   r*   )r+   s   "r,   r-   ServerSentEvent.__annotate__   s>        	
   
r/   c               	X    Vf   RpW0n         W n        T;'       g    R V n        W@n        R # )N )_id_data_event_retry)r9   r\   r[   r   r   s   &$$$$r,   r:   ServerSentEvent.__init__   s*     <D
mmtr/   c                   V ^8  d   QhRR/# r$   r(   r   r*   )r+   s   "r,   r-   r           z r/   c                	    V P                   # r1   )r   rA   s   &r,   r\   ServerSentEvent.event      {{r/   c                   V ^8  d   QhRR/# r   r*   )r+   s   "r,   r-   r     s      J r/   c                	    V P                   # r1   )r   rA   s   &r,   r   ServerSentEvent.id  s    xxr/   c                   V ^8  d   QhRR/# )r$   r(   r   r*   )r+   s   "r,   r-   r     r   r/   c                	    V P                   # r1   )r   rA   s   &r,   r   ServerSentEvent.retry  r   r/   c                   V ^8  d   QhRR/# r$   r(   rc   r*   )r+   s   "r,   r-   r     s      c r/   c                	    V P                   # r1   )r   rA   s   &r,   r[   ServerSentEvent.data  s    zzr/   c                   V ^8  d   QhRR/# )r$   r(   r   r*   )r+   s   "r,   r-   r     s     % %c %r/   c                	B    \         P                  ! V P                  4      # r1   )r`   loadsr[   rA   s   &r,   r`   ServerSentEvent.json  s    zz$))$$r/   c                   V ^8  d   QhRR/# r   r*   )r+   s   "r,   r-   r     s     j j# jr/   c           	     	p    R V P                    RV P                   RV P                   RV P                   R2	# )zServerSentEvent(event=z, data=z, id=z, retry=)r\   r[   r   r   rA   s   &r,   __repr__ServerSentEvent.__repr__  s9    '

|7499+U477)S[\`\f\f[gghiir/   )r   r   r   r   )r   r   r   r   r:   propertyr\   r   r   r[   r`   r   r   r   r*   r/   r,   r   r      s     !  	
  !         % j jr/   r   c                      ] tR tRt$ R]R&   R]R&   R]R&   R]R&   R	 R
 ltR R ltR R ltR R ltR R lt	R R lt
RtR# )
SSEDecoderi  z	list[str]r   r   r   r   r   _last_event_idc                   V ^8  d   QhRR/# r{   r*   )r+   s   "r,   r-   SSEDecoder.__annotate__!  s      $ r/   c                	>    R V n         . V n        R V n        R V n        R # r1   )r   r   r   r   rA   s   &r,   r:   SSEDecoder.__init__!  s    
"r/   c                    V ^8  d   QhRRRR/# r$   rh   Iterator[bytes]r(   rL   r*   )r+   s   "r,   r-   r   '  s      ? 7P r/   c              #     "   V P                  V4       FJ  pVP                  4        F3  pVP                  R4      pV P                  V4      pV'       g   K/  Vx  K5  	  KL  	  R# 5i)^Given an iterator that yields raw binary data, iterate over it & yield every event encounteredutf-8N)_iter_chunks
splitlinesdecoder9   rh   chunkraw_linelineri   s   &&    r,   rN   SSEDecoder.iter_bytes'  sS     &&x0E!,,.w/kk$'3I	 / 1s   AA$A$c                    V ^8  d   QhRRRR/# )r$   rh   r   r(   r*   )r+   s   "r,   r-   r   1  s     
 
_ 
 
r/   c              #     "   RpV FC  pVP                  RR7       F*  pW$,          pVP                  R4      '       g   K$  Vx  RpK,  	  KE  	  V'       d   Vx  R# R# 5i)^Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunksr/   TkeependsNs   s   

s   

r   endswithr9   rh   r[   r   r   s   &&   r,   r   SSEDecoder._iter_chunks1  s\     E(($(7==!@AAJD	 8  J s   9A AAc                    V ^8  d   QhRRRR/# r$   rh   AsyncIterator[bytes]r(   r   r*   )r+   s   "r,   r-   r   =  s      *> Ca r/   c                  "   V P                  V4        Rj  xL
  pVP                  4        F4  pVP                  R4      pV P                  V4      pV'       g   K/  V5x  K6  	  KT   LODPR# 5i)r   Nr   )_aiter_chunksr   r   r   s   &&    r,   r   SSEDecoder.aiter_bytes=  s`     --h7 	 	%!,,.w/kk$'3I	 /	7s+   A-A*A(A*<A-A-(A**A-c                    V ^8  d   QhRRRR/# )r$   rh   r   r(   r*   )r+   s   "r,   r-   r   G  s     
 
,@ 
EY 
r/   c                  "   RpV  Rj  xL
  pVP                  RR7       F+  pW$,          pVP                  R4      '       g   K$  V5x  RpK-  	  KM   LHDIT'       d   T5x  R# R# 5i)r   r/   NTr   r   r   r   s   &&   r,   r   SSEDecoder._aiter_chunksG  sh     # 	 	%(($(7==!@AAJD	 8	8 J s1   A(AAA3A(A(AA(	A(c                    V ^8  d   QhRRRR/# )r$   r   rc   r(   zServerSentEvent | Noner*   )r+   s   "r,   r-   r   S  s     . .3 .#9 .r/   c                	   V'       g   V P                   '       g5   V P                  '       g#   V P                  '       g   V P                  f   R # \	        V P                   RP                  V P                  4      V P                  V P                  R7      pR V n         . V n        R V n        V# VP                  R4      '       d   R # VP                  R4      w  r4pVP                  R4      '       d
   VR,          pVR8X  d	   WPn         R # VR8X  d   V P                  P                  V4       R # VR8X  d   R	V9   d    R # WPn         R # VR
8X  d    \        V4      V n        R #  R #   \        \        3 d     R # i ; i)N
r   : :   NNr\   r[   r    r   )r   r   r   r   r   joinr_   	partitionappendint	TypeError
ValueError)r9   r   ri   	fieldname_values   &&    r,   r   SSEDecoder.decodeS  s\    ;;;tzzz$:M:M:MRVR]R]Re!kkYYtzz*&&kk	C DKDJDKJ??3"nnS1	eC  "IEK   & JJe$  $u}  ',#  '!!%j   z*  s   E# #E87E8)r   r   r   r   N)r   r   r   r   r   r:   rN   r   r   r   r   r   r*   r/   r,   r   r     s=    

. .r/   r   c                  .    ] tR tRtR R ltR R ltRtR# )r    i  c                    V ^8  d   QhRRRR/# r   r*   )r+   s   "r,   r-   SSEBytesDecoder.__annotate__  s      ? 7P r/   c                    R# )r   Nr*   r9   rh   s   &&r,   rN   SSEBytesDecoder.iter_bytes      r/   c                    V ^8  d   QhRRRR/# r   r*   )r+   s   "r,   r-   r    s      $8 =[ r/   c                    R# )zdGiven an async iterator that yields raw binary data, iterate over it & yield every event encounteredNr*   r  s   &&r,   r   SSEBytesDecoder.aiter_bytes  r  r/   r*   N)r   r   r   r   rN   r   r   r*   r/   r,   r    r      s     r/   r    c                    V ^8  d   QhRRRR/# )r$   typtyper(   z;TypeGuard[type[Stream[object]] | type[AsyncStream[object]]]r*   )r+   s   "r,   r-   r-     s     Q Qd Q'b Qr/   c                    \        V 4      ;'       g    T p\        P                  ! V4      ;'       d    \        V\        \
        34      # )zaTypeGuard for determining whether or not the given type is a subclass of `Stream` / `AsyncStream`)r   inspectisclass
issubclassr   r   )r  origins   & r,   is_stream_class_typer    s6    _##F??6"PPz&6;:O'PPr/   failure_messagec               $    V ^8  d   QhRRRRRR/# )r$   
stream_clsr  r   r   r(   r*   )r+   s   "r,   r-   r-     s(         
	r/   c          	     F    ^RI HpHp \        V ^ \	        RW#34      VR7      # )zGiven a type like `Stream[T]`, returns the generic type variable `T`.

This also handles the case where a concrete subclass is given, e.g.
```py
class MyStream(Stream[bytes]):
    ...

extract_stream_chunk_type(MyStream) -> bytes
```
)r   r   ztuple[type, ...])indexgeneric_basesr   )_base_clientr   r   r   r   )r"  r   r   r   s   &$  r,   extract_stream_chunk_typer'    s+     2%-/DE'	 r/   ))
__future__r   r`   r  typesr   typingr   r   r   r   r	   r
   r   r   typing_extensionsr   r   r   r   r   r   httpx_utilsr   r   _exceptionsr   r4   r   r   _modelsr   r   r   r   r   r   r    r  r'  r*   r/   r,   <module>r0     s    "    ` ` ` ` `  : !,, T]jWR[ jZk%'"+ k%\&j &jRf fR h  Q #' r/   