Ë
    $Æ%hm?  ã                  óÖ  — U d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZm	Z	m
Z
mZmZmZmZmZmZmZ d dlmZmZmZmZmZ d dlZd dlZd dlZddlmZ ddlmZmZm Z m!Z! ddl"m#Z#m$Z$m%Z% dd	l&m'Z' dd
l(m)Z)m*Z*m+Z+m,Z, ddl-m.Z. erddl"m/Z/ ddl0m1Z1  ed«      Z2 ed«      Z3 ed«      Z4 ejj                  e6«      Z7de8d<    G d„ dee3   «      Z9 G d„ de:«      Z;dd„Z<dd„Z= G d„ d«      Z>y)é    )ÚannotationsN)
ÚTYPE_CHECKINGÚAnyÚUnionÚGenericÚTypeVarÚCallableÚIteratorÚAsyncIteratorÚcastÚoverload)Ú	AwaitableÚ	ParamSpecÚoverrideÚ
deprecatedÚ
get_originé   )ÚNoneType)Úis_givenÚextract_type_argÚis_annotated_typeÚis_type_alias_type)Ú	BaseModelÚis_basemodelÚadd_request_id)ÚRAW_RESPONSE_HEADER)ÚStreamÚAsyncStreamÚis_stream_class_typeÚextract_stream_chunk_type)ÚAPIResponseValidationError)ÚFinalRequestOptions)Ú
BaseClientÚPÚRÚ_Tzlogging.LoggerÚlogc                  ó¨  — e Zd ZU dZded<   ded<   ded<   ded	<   d
ed<   ded<   ded<   ded<   	 ddœ	 	 	 	 	 	 	 	 	 	 	 	 	 	 	 d'd„Zed(d„«       Zed)d„«       Z	ed*d„«       Z	ddœd+d„Z	ed,d„«       Z
ed-d„«       Zed.d„«       Zed/d„«       Zed0d„«       Zed1d „«       Zed0d!„«       Zed0d"„«       Zed2d#„«       Zed3d$„«       Zddœd+d%„Zed0d&„«       Zy)4ÚLegacyAPIResponsea°  This is a legacy class as it will be replaced by `APIResponse`
    and `AsyncAPIResponse` in the `_response.py` file in the next major
    release.

    For the sync client this will mostly be the same with the exception
    of `content` & `text` will be methods instead of properties. In the
    async client, all methods will be async.

    A migration script will be provided & the migration in general should
    be smooth.
    útype[R]Ú_cast_toúBaseClient[Any, Any]Ú_clientzdict[type[Any], Any]Ú_parsed_by_typeÚboolÚ_streamú1type[Stream[Any]] | type[AsyncStream[Any]] | NoneÚ_stream_clsr"   Ú_optionsúhttpx.ResponseÚhttp_responseÚintÚretries_takenr   )r7   c               ót   — || _         || _        i | _        || _        || _        || _        || _        || _        y ©N)r+   r-   r.   r0   r2   r3   r5   r7   )ÚselfÚrawÚcast_toÚclientÚstreamÚ
stream_clsÚoptionsr7   s           úU/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/openai/_legacy_response.pyÚ__init__zLegacyAPIResponse.__init__F   s@   € ð  ˆŒØˆŒØ!ˆÔØˆŒØ%ˆÔØˆŒØ ˆÔØ*ˆÕó    c                óL   — | j                   j                  j                  d«      S )Nzx-request-id)r5   ÚheadersÚget©r:   s    rA   Ú
request_idzLegacyAPIResponse.request_idZ   s   € à×!Ñ!×)Ñ)×-Ñ-¨nÓ=Ð=rC   c                ó   — y r9   © )r:   Útos     rA   ÚparsezLegacyAPIResponse.parse^   s   € Ø,/rC   c                 ó   — y r9   rJ   rG   s    rA   rL   zLegacyAPIResponse.parsea   s   € ØrC   N©rK   c               ó‚  — |�|n| j                   }| j                  j                  |«      }|�|S | j                  |¬«      }t	        | j
                  j                  «      r| j
                  j                  |«      }t        |t        «      rt        || j                  «       || j                  |<   t        t        |«      S )aÞ  Returns the rich python representation of this response's data.

        NOTE: For the async client: this will become a coroutine in the next major version.

        For lower-level control, see `.read()`, `.json()`, `.iter_bytes()`.

        You can customise the type that the response is parsed into through
        the `to` argument, e.g.

        ```py
        from openai import BaseModel


        class MyModel(BaseModel):
            foo: str


        obj = response.parse(to=MyModel)
        print(obj.foo)
        ```

        We support parsing:
          - `BaseModel`
          - `dict`
          - `list`
          - `Union`
          - `str`
          - `int`
          - `float`
          - `httpx.Response`
        rN   )r+   r.   rF   Ú_parser   r3   Úpost_parserÚ
isinstancer   r   rH   r   r%   )r:   rK   Ú	cache_keyÚcachedÚparseds        rA   rL   zLegacyAPIResponse.parsed   sŸ   € ð@ ˜.‘B¨d¯m©mˆ	Ø×%Ñ%×)Ñ)¨)Ó4ˆØÐØˆMà—‘ �Ó#ˆÜ�D—M‘M×-Ñ-Ô.Ø—]‘]×.Ñ.¨vÓ6ˆFä�fœiÔ(Ü˜6 4§?¡?Ô3à*0ˆ×Ñ˜YÑ'Ü”A�v‹ÐrC   c                ó.   — | j                   j                  S r9   )r5   rE   rG   s    rA   rE   zLegacyAPIResponse.headers“   ó   € à×!Ñ!×)Ñ)Ð)rC   c                ó.   — | j                   j                  S r9   )r5   ÚrequestrG   s    rA   Úhttp_requestzLegacyAPIResponse.http_request—   rW   rC   c                ó.   — | j                   j                  S r9   )r5   Ústatus_coderG   s    rA   r\   zLegacyAPIResponse.status_code›   s   € à×!Ñ!×-Ñ-Ð-rC   c                ó.   — | j                   j                  S r9   )r5   ÚurlrG   s    rA   r^   zLegacyAPIResponse.urlŸ   s   € à×!Ñ!×%Ñ%Ð%rC   c                ó.   — | j                   j                  S r9   )rZ   ÚmethodrG   s    rA   r`   zLegacyAPIResponse.method£   s   € à× Ñ ×'Ñ'Ð'rC   c                ó.   — | j                   j                  S )zŠReturn the binary response content.

        NOTE: this will be removed in favour of `.read()` in the
        next major version.
        )r5   ÚcontentrG   s    rA   rb   zLegacyAPIResponse.content§   s   € ð ×!Ñ!×)Ñ)Ð)rC   c                ó.   — | j                   j                  S )zyReturn the decoded response content.

        NOTE: this will be turned into a method in the next major version.
        )r5   ÚtextrG   s    rA   rd   zLegacyAPIResponse.text°   s   € ð ×!Ñ!×&Ñ&Ð&rC   c                ó.   — | j                   j                  S r9   )r5   Úhttp_versionrG   s    rA   rf   zLegacyAPIResponse.http_version¸   s   € à×!Ñ!×.Ñ.Ð.rC   c                ó.   — | j                   j                  S r9   )r5   Ú	is_closedrG   s    rA   rh   zLegacyAPIResponse.is_closed¼   s   € à×!Ñ!×+Ñ+Ð+rC   c                ó.   — | j                   j                  S )zCThe time taken for the complete request/response cycle to complete.)r5   ÚelapsedrG   s    rA   rj   zLegacyAPIResponse.elapsedÀ   s   € ð ×!Ñ!×)Ñ)Ð)rC   c               óà	  — |�|n| j                   }t        |«      r|j                  }|rt        |«      rt	        |d«      }t        |«      xs |}| j                  �r6|rjt        |«      st        dt        › dt        › �«      ‚t        t         |t        |d¬«      | j                  t        t        | j                   «      ¬«      «      S | j"                  rWt        t$        | j#                  t        | j"                  «      | j                  t        t        | j                   «      ¬«      «      S t        d| j                   j&                  «      }|€
t)        «       ‚t        t$         ||| j                  t        t        | j                   «      ¬«      «      S |t*        u rt        t$        d «      S | j                  }|t,        k(  rt        t$        |j.                  «      S |t0        k(  r#t        t$        t1        |j.                  «      «      S |t2        k(  r#t        t$        t3        |j.                  «      «      S |t4        k(  r+t        t$        |j.                  j7                  «       dk(  «      S t9        j:                  |«      r&t=        |t>        «      rt        t$         ||«      «      S |t@        k(  rtC        d	«      ‚t9        j:                  |«      rHt=        |tD        jF                  «      r.|tD        jF                  k7  rtI        d
«      ‚t        t$        |«      S t9        j:                  |«      r5t=        |tJ        «      s%t=        |tL        jJ                  «      rt        d«      ‚|tN        urr|tP        urj|tR        urb|tT        urZt=        |tJ        «      sJtC        d|› dtJ        › dtR        › dtP        › dtT        › dt*        › dt,        › dtD        jF                  › d�«      ‚|jV                  jY                  dd«      j[                  d«      ^}}|j]                  d«      sxt_        |«      r/	 |ja                  «       }| j                   jc                  |||¬«      S | j                   jl                  rto        |d|› d�|j.                  ¬«      ‚|j.                  S |ja                  «       }| j                   jc                  |||¬«      S # td        $ r*}	tf        ji                  dtk        |	«      |	«       Y d }	~	Œšd }	~	ww xY w)Nr   z/Expected custom parse type to be a subclass of z or zUExpected custom stream type to be passed with a type argument, e.g. Stream[ChunkType])Úfailure_message)r<   Úresponser=   r1   Útruez+Unexpected state - cast_to is `APIResponse`z:Subclasses of httpx.Response cannot be passed to `cast_to`zVPydantic models must subclass our base model type, e.g. `from openai import BaseModel`zUnsupported type, expected z to be a subclass of z, ú.zcontent-typeÚ*ú;Újson)Údatar<   rm   z5Could not read JSON from response data due to %s - %szMExpected Content-Type response header to be `application/json` but received `z
` instead.)rm   ÚmessageÚbody)8r+   r   Ú	__value__r   r   r   r0   r   Ú	TypeErrorr   r   r   r&   r    r5   r   r-   r2   r%   Ú_default_stream_clsÚMissingStreamClassErrorr   Ústrrd   r6   Úfloatr/   ÚlowerÚinspectÚisclassÚ
issubclassÚHttpxBinaryResponseContentr)   ÚRuntimeErrorÚhttpxÚResponseÚ
ValueErrorr   ÚpydanticÚobjectÚlistÚdictr   rE   rF   ÚsplitÚendswithr   rr   Ú_process_response_dataÚ	Exceptionr'   ÚdebugÚtypeÚ_strict_response_validationr!   )
r:   rK   r<   Úoriginr?   rm   Úcontent_typeÚ_rs   Úexcs
             rA   rP   zLegacyAPIResponse._parseÅ   sŒ  € Ø˜‘"¨D¯M©Mˆô ˜gÔ&Ø×'Ñ'ˆGñ Ô(¨Ô1Ü& w°Ó2ˆGä˜GÓ$Ò/¨ˆà�<‹<ÙÜ+¨BÔ/Ü#Ð&UÔV\ÐU]Ð]aÔbmÐanÐ$oÓpÐpäÜÙÜ 9Øð -Dô!ð "&×!3Ñ!3Ü#¤C¨¯©Ó6ôó
ð 
ð ×ÒÜÜØ×$Ñ$Ü 9¸$×:JÑ:JÓ KØ!%×!3Ñ!3Ü#¤C¨¯©Ó6ð %ó óð ô ÐQÐSW×S_ÑS_×SsÑSsÓtˆJØÐ!Ü-Ó/Ð/äÜÙØ#Ø!×/Ñ/Ü¤ T§\¡\Ó2ôóð ð ”hÑÜœ˜4“=Ð à×%Ñ%ˆØ”cŠ>Üœ˜8Ÿ=™=Ó)Ð)à”cŠ>Üœœ3˜xŸ}™}Ó-Ó.Ð.à”eÒÜœœ5 §¡Ó/Ó0Ð0à”dŠ?Üœ˜8Ÿ=™=×.Ñ.Ó0°FÑ:Ó;Ð;ä�?‰?˜6Ô"¤z°&Ô:TÔ'UÜœ™7 8Ó,Ó-Ð-àÔ&Ò&ÜÐLÓMÐMä�?‰?Øô
ä˜¤§¡Ô0ð œ%Ÿ.™.Ò(Ü Ð#]Ó_Ð_Üœ˜8Ó$Ð$ô �O‰OØôô ˜v¤yÔ1Ü˜6¤8×#5Ñ#5Ô6äÐtÓuÐuð œ6Ñ!Øœd‘NØœd‘NØœe‘OÜ˜v¤yÔ1äØ-¨g¨YÐ6KÌIÈ;ÐVXÔY]ÐX^Ð^`ÔaeÐ`fÐfhÔinÐhoÐoqÔrzÐq{Ð{}ô  Bð  ~Cð  CGô  HM÷  HVñ  HVð  GWð  WXð  Yóð ð $×+Ñ+×/Ñ/°ÀÓD×JÑJÈ3ÓOÐˆ�qØ×$Ñ$ VÔ,Ü˜GÔ$ð	Ø#Ÿ=™=›?�Dð  Ÿ<™<×>Ñ>Ø!Ø 'Ø!)ð ?ó ð ð �|‰|×7Ò7Ü0Ø%ØkÐlxÐkyð  zDð  EØ!Ÿ™ôð ð —=‘=Ð à�}‰}‹ˆà�|‰|×2Ñ2ØØØð 3ó 
ð 	
øô/ !ò gÜ—I‘IÐUÔW[Ð\_ÓW`Ðbe×fÑfûðgús   Ð R: Ò:	S-Ó S(Ó(S-c                ój   — d| j                   › d| j                  j                  › d| j                  › d�S )Nz<APIResponse [ú z] type=ú>)r\   r5   Úreason_phraser+   rG   s    rA   Ú__repr__zLegacyAPIResponse.__repr__T  s;   € à × 0Ñ 0Ð1°°4×3EÑ3E×3SÑ3SÐ2TÐT[Ð\`×\iÑ\iÐ[jÐjkÐlÐlrC   )r;   r4   r<   r*   r=   r,   r>   r/   r?   r1   r@   r"   r7   r6   ÚreturnÚNone©r™   z
str | None)rK   ztype[_T]r™   r&   )r™   r%   )rK   ztype[_T] | Noner™   zR | _T)r™   zhttpx.Headers)r™   zhttpx.Request)r™   r6   )r™   z	httpx.URL©r™   rz   ©r™   Úbytes)r™   r/   )r™   zdatetime.timedelta)Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__rB   ÚpropertyrH   r   rL   rE   rZ   r\   r^   r`   rb   rd   rf   rh   rj   rP   r   r˜   rJ   rC   rA   r)   r)   -   s»  … ñ
ð ÓØ!Ó!Ø)Ó)ØƒMØBÓBØ!Ó!à!Ó!àÓØMð ñ+ð ð+ð ð	+ð
 %ð+ð ð+ð Fð+ð %ð+ð ð+ð 
ó+ð( ò>ó ð>ð Ú/ó Ø/àÚó Øà-1õ -ð^ ò*ó ð*ð ò*ó ð*ð ò.ó ð.ð ò&ó ð&ð ò(ó ð(ð ò*ó ð*ð ò'ó ð'ð ò/ó ð/ð ò,ó ð,ð ò*ó ð*ð /3õ M
ð^ òmó ñmrC   r)   c                  ó    ‡ — e Zd Zdˆ fd„Zˆ xZS )ry   c                ó$   •— t         ‰| �  d«       y )NzzThe `stream` argument was set to `True` but the `stream_cls` argument was not given. See `openai._streaming` for reference)ÚsuperrB   )r:   Ú	__class__s    €rA   rB   z MissingStreamClassError.__init__Z  s   ø€ Ü‰Ñð Iõ	
rC   ©r™   rš   )rŸ   r    r¡   rB   Ú__classcell__)r¨   s   @rA   ry   ry   Y  s   ø„ ÷
ñ 
rC   ry   c                óD   ‡ — t        j                  ‰ «      dˆ fd„«       }|S )ú�Higher order function that takes one of our bound API methods and wraps it
    to support returning the raw `APIResponse` object directly.
    c                 ó¤   •— i t        t        |j                  d«      «      xs i ¥}d|t        <   ||d<   t        t        t
            ‰| i |¤Ž«      S ©NÚextra_headersrn   ©r   r   rF   r   r)   r%   ©ÚargsÚkwargsr¯   Úfuncs      €rA   Úwrappedz(to_raw_response_wrapper.<locals>.wrappede  sU   ø€ à(Z¬D´°f·j±jÀÓ6QÓ,RÒ,XÐVXÐ(ZˆØ-3ˆÔ)Ñ*à"/ˆˆÑäÔ%¤aÑ(©$°Ð*?¸Ñ*?Ó@Ð@rC   ©r²   zP.argsr³   zP.kwargsr™   zLegacyAPIResponse[R]©Ú	functoolsÚwraps©r´   rµ   s   ` rA   Úto_raw_response_wrapperr»   `  s)   ø€ ô
 ‡_�_�TÓôAó ðAð €NrC   c                óD   ‡ — t        j                  ‰ «      dˆ fd„«       }|S )r¬   c               Ÿ  óÀ   •K  — i t        t        |j                  d«      «      xs i ¥}d|t        <   ||d<   t        t        t
            ‰| i |¤Žƒ d {  –—† «      S 7 Œ­wr®   r°   r±   s      €rA   rµ   z.async_to_raw_response_wrapper.<locals>.wrappedv  s_   øè ø€ à(Z¬D´°f·j±jÀÓ6QÓ,RÒ,XÐVXÐ(ZˆØ-3ˆÔ)Ñ*à"/ˆˆÑäÔ%¤aÑ(±°dÐ0E¸fÑ0E×*EÓFÐFÐ*Eús   ƒAAÁA
Á	Ar¶   r·   rº   s   ` rA   Úasync_to_raw_response_wrapperr¾   q  s)   ø€ ô
 ‡_�_�TÓôGó ðGð €NrC   c                  óH  — e Zd ZU ded<   dd„Zedd„«       Zedd„«       Zedd„«       Zedd„«       Z	dd„Z
dd	„Zd d!d„Zd d"d„Zd#d„Zd d!d„Z	 	 	 	 d$d„Z ed«      d
dœ	 	 	 	 	 d%d„«       Zd&d„Zdd„Zd d'd„Zd d(d„Zd)d„Zd d'd„Z ed«      d
dœ	 	 	 	 	 d%d„«       Zd&d„Zy
)*r€   r4   rm   c                ó   — || _         y r9   )rm   )r:   rm   s     rA   rB   z#HttpxBinaryResponseContent.__init__…  s	   € Ø ˆ�rC   c                ó.   — | j                   j                  S r9   )rm   rb   rG   s    rA   rb   z"HttpxBinaryResponseContent.contentˆ  s   € à�}‰}×$Ñ$Ð$rC   c                ó.   — | j                   j                  S r9   )rm   rd   rG   s    rA   rd   zHttpxBinaryResponseContent.textŒ  s   € à�}‰}×!Ñ!Ð!rC   c                ó.   — | j                   j                  S r9   )rm   ÚencodingrG   s    rA   rÄ   z#HttpxBinaryResponseContent.encoding�  s   € à�}‰}×%Ñ%Ð%rC   c                ó.   — | j                   j                  S r9   )rm   Úcharset_encodingrG   s    rA   rÆ   z+HttpxBinaryResponseContent.charset_encoding”  s   € à�}‰}×-Ñ-Ð-rC   c                ó:   —  | j                   j                  di |¤ŽS )NrJ   )rm   rr   )r:   r³   s     rA   rr   zHttpxBinaryResponseContent.json˜  s   € Ø!ˆt�}‰}×!Ñ!Ñ+ FÑ+Ð+rC   c                ó6   — | j                   j                  «       S r9   )rm   ÚreadrG   s    rA   rÉ   zHttpxBinaryResponseContent.read›  s   € Ø�}‰}×!Ñ!Ó#Ð#rC   Nc                ó8   — | j                   j                  |«      S r9   )rm   Ú
iter_bytes©r:   Ú
chunk_sizes     rA   rË   z%HttpxBinaryResponseContent.iter_bytesž  s   € Ø�}‰}×'Ñ'¨
Ó3Ð3rC   c                ó8   — | j                   j                  |«      S r9   )rm   Ú	iter_textrÌ   s     rA   rÏ   z$HttpxBinaryResponseContent.iter_text¡  s   € Ø�}‰}×&Ñ& zÓ2Ð2rC   c                ó6   — | j                   j                  «       S r9   )rm   Ú
iter_linesrG   s    rA   rÑ   z%HttpxBinaryResponseContent.iter_lines¤  s   € Ø�}‰}×'Ñ'Ó)Ð)rC   c                ó8   — | j                   j                  |«      S r9   )rm   Úiter_rawrÌ   s     rA   rÓ   z#HttpxBinaryResponseContent.iter_raw§  s   € Ø�}‰}×%Ñ% jÓ1Ð1rC   c                óª   — t        |d¬«      5 }| j                  j                  «       D ]  }|j                  |«       Œ 	 ddd«       y# 1 sw Y   yxY w)av  Write the output to the given file.

        Accepts a filename or any path-like object, e.g. pathlib.Path

        Note: if you want to stream the data to the file instead of writing
        all at once then you should use `.with_streaming_response` when making
        the API request, e.g. `client.with_streaming_response.foo().stream_to_file('my_filename.txt')`
        Úwb©ÚmodeN©Úopenrm   rË   Úwrite)r:   ÚfileÚfrs   s       rA   Úwrite_to_filez(HttpxBinaryResponseContent.write_to_fileª  sL   € ô �$˜TÔ"ð 	 aØŸ™×0Ñ0Ó2ò �Ø—‘˜•ñ÷	÷ 	ñ 	ús   Ž1A	Á	Az‚Due to a bug, this method doesn't actually stream the response content, `.with_streaming_response.method()` should be used instead)rÍ   c               ó¬   — t        |d¬«      5 }| j                  j                  |«      D ]  }|j                  |«       Œ 	 d d d «       y # 1 sw Y   y xY w©NrÕ   rÖ   rØ   )r:   rÛ   rÍ   rÜ   rs   s        rA   Ústream_to_filez)HttpxBinaryResponseContent.stream_to_fileº  sN   € ô �$˜TÔ"ð 	 aØŸ™×0Ñ0°Ó<ò �Ø—‘˜•ñ÷	÷ 	ñ 	ús   Ž2A
Á
Ac                ó6   — | j                   j                  «       S r9   )rm   ÚcloserG   s    rA   râ   z HttpxBinaryResponseContent.closeÇ  s   € Ø�}‰}×"Ñ"Ó$Ð$rC   c              ƒ  óR   K  — | j                   j                  «       ƒ d {  –—† S 7 Œ­wr9   )rm   ÚareadrG   s    rA   rä   z HttpxBinaryResponseContent.areadÊ  s   è ø€ Ø—]‘]×(Ñ(Ó*×*Ð*Ð*úó   ‚' %¡'c              ƒ  ó@   K  — | j                   j                  |«      S ­wr9   )rm   Úaiter_bytesrÌ   s     rA   rç   z&HttpxBinaryResponseContent.aiter_bytesÍ  s   è ø€ Ø�}‰}×(Ñ(¨Ó4Ð4ùó   ‚c              ƒ  ó@   K  — | j                   j                  |«      S ­wr9   )rm   Ú
aiter_textrÌ   s     rA   rê   z%HttpxBinaryResponseContent.aiter_textÐ  s   è ø€ Ø�}‰}×'Ñ'¨
Ó3Ð3ùrè   c              ƒ  ó>   K  — | j                   j                  «       S ­wr9   )rm   Úaiter_linesrG   s    rA   rì   z&HttpxBinaryResponseContent.aiter_linesÓ  s   è ø€ Ø�}‰}×(Ñ(Ó*Ð*ùs   ‚c              ƒ  ó@   K  — | j                   j                  |«      S ­wr9   )rm   Ú	aiter_rawrÌ   s     rA   rî   z$HttpxBinaryResponseContent.aiter_rawÖ  s   è ø€ Ø�}‰}×&Ñ& zÓ2Ð2ùrè   c             ƒ  óV  K  — t        j                  |«      }|j                  d¬«      ƒ d {  –—† 4 ƒd {  –—† }| j                  j	                  |«      2 3 d {  –—† }|j                  |«      ƒ d {  –—†  Œ#7 ŒK7 ŒD7 Œ"7 Œ6 d d d «      ƒd {  –—†7   y # 1 ƒd {  –—†7  sw Y   y xY w­wrß   )ÚanyioÚPathrÙ   rm   rç   rÚ   )r:   rÛ   rÍ   ÚpathrÜ   rs   s         rA   Úastream_to_filez*HttpxBinaryResponseContent.astream_to_fileÙ  s—   è ø€ ô �z‰z˜$ÓˆØŸ™¨˜Ó-×-÷ 	$ð 	$°Ø"Ÿm™m×7Ñ7¸
ÓC÷ $ð $�dØ—g‘g˜d“m×#Ñ#ð .øð 	$øð$øØ#øð D÷	$÷ 	$÷ 	$÷ 	$ó 	$üsŠ   ‚+B)­A9®B)¶A;·B)ºBÁBÁA=ÁBÁBÁ3A?Á4BÁ9B)Á;B)Á=BÁ?BÂBÂB)ÂBÂB)ÂB&ÂBÂB&Â"B)c              ƒ  óR   K  — | j                   j                  «       ƒ d {  –—† S 7 Œ­wr9   )rm   ÚacloserG   s    rA   rõ   z!HttpxBinaryResponseContent.acloseç  s   è ø€ Ø—]‘]×)Ñ)Ó+×+Ð+Ð+úrå   )rm   r4   r™   rš   r�   rœ   r›   )r³   r   r™   r   r9   )rÍ   ú
int | Noner™   zIterator[bytes])rÍ   rö   r™   úIterator[str])r™   r÷   )rÛ   ústr | os.PathLike[str]r™   rš   )rÛ   rø   rÍ   rö   r™   rš   r©   )rÍ   rö   r™   zAsyncIterator[bytes])rÍ   rö   r™   úAsyncIterator[str])r™   rù   )rŸ   r    r¡   r£   rB   r¤   rb   rd   rÄ   rÆ   rr   rÉ   rË   rÏ   rÑ   rÓ   rÝ   r   rà   râ   rä   rç   rê   rì   rî   ró   rõ   rJ   rC   rA   r€   r€   ‚  s5  … ØÓó!ð ò%ó ð%ð ò"ó ð"ð ò&ó ð&ð ò.ó ð.ó,ó$ô4ô3ó*ô2ðà$ðð 
óñ  ð 	Móð "&ñ	à$ðð ð	ð
 
òóðó%ó+ô5ô4ó+ô3ñ ð 	Móð "&ñ		$à$ð	$ð ð		$ð
 
ò	$óð	$ô,rC   r€   )r´   zCallable[P, R]r™   z!Callable[P, LegacyAPIResponse[R]])r´   zCallable[P, Awaitable[R]]r™   z,Callable[P, Awaitable[LegacyAPIResponse[R]]])?Ú
__future__r   Úosr}   ÚloggingÚdatetimer¸   Útypingr   r   r   r   r   r	   r
   r   r   r   Útyping_extensionsr   r   r   r   r   rð   r‚   r…   Ú_typesr   Ú_utilsr   r   r   r   Ú_modelsr   r   r   Ú
_constantsr   Ú
_streamingr   r   r   r    Ú_exceptionsr!   r"   Ú_base_clientr#   r$   r%   r&   Ú	getLoggerrŸ   r'   r£   r)   rw   ry   r»   r¾   r€   rJ   rC   rA   ú<module>r     sÇ   ðÞ "ã 	Û Û Û Û ÷÷ ÷ ÷ UÕ Tã Û Û å ß UÓ Uß <Ñ <Ý +ß \Ó \Ý 3áÝ,Ý(ñ ˆcƒN€ÙˆCƒL€ÙˆTƒ]€à'�g×'Ñ'¨Ó1€€^Ó 1ôim˜ ™
ô imôX	
˜iô 
óó"÷"f,ò f,rC   