ó
    ±"³j6z  ã                  óþ  • S SK Jr  S SKJrJrJrJrJrJr  S SK	J	r	  S SK
Jr  S SKJr  S SKr\(       a  S SKJr  SS	KJr  SS
KJrJr  SSKJrJrJrJrJrJrJrJr  SSKJ r J!r!J"r"  SSK#J$r$  SSK%J&r&J'r'  SSK(J)r)J*r*J+r+J,r,  SSK-J.r.J/r/  SSK0J1r1J2r2  SSK3J4r4J5r5  SSK6J7r7  SSK8J9r9  SSK:J;r;  SSK<J=r=  SSK>J?r?  SSK@JArA  SS/rB " S S\&5      rC " S S\'5      rD " S S5      rE " S S 5      rF " S! S"5      rG " S# S$5      rHg)%é    )Úannotations)ÚTYPE_CHECKINGÚAnyÚListÚUnionÚIterableÚcast)Údatetime)Úchain)ÚLiteralN)ÚSequenceé   )ÚAsyncAnthropic)ÚSessionToolRunnerÚBetaAnyRunnableTool)ÚBodyÚOmitÚQueryÚHeadersÚNotGivenÚSequenceNotStrÚomitÚ	not_given)Úis_givenÚpath_templateÚstrip_not_given)Úcached_property)ÚSyncAPIResourceÚAsyncAPIResource)Úto_raw_response_wrapperÚto_streamed_response_wrapperÚasync_to_raw_response_wrapperÚ"async_to_streamed_response_wrapper)ÚStreamÚAsyncStream)ÚSyncPageCursorÚAsyncPageCursor)ÚAsyncPaginatorÚmake_request_options)ÚAnthropicBetaParam)ÚBetaManagedAgentsDeltaType)ÚBetaManagedAgentsEventParams)ÚBetaManagedAgentsSessionEvent)Ú"BetaManagedAgentsSendSessionEvents)Ú$BetaManagedAgentsStreamSessionEventsÚEventsÚAsyncEventsc                  ó$  • \ rS rSr\SS j5       r\SS j5       r\\\\\\\\\\SSS\S.                               SS jjr	\\SSS\S.                 SS jjr
\\\SSS\S	.                 SS
 jjrSrg)r0   é'   c                ó   • [        U 5      $ ©zú
This property can be used as a prefix for any HTTP method call to return
the raw response object instead of the parsed content.

For more information, see https://www.github.com/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers
)ÚEventsWithRawResponse©Úselfs    Úe/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anthropic/resources/beta/sessions/events.pyÚwith_raw_responseÚEvents.with_raw_response(   s   € ô % TÓ*Ð*ó    c                ó   • [        U 5      $ ©z¿
An alternative to `.with_raw_response` that doesn't eagerly read the response body.

For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response
)ÚEventsWithStreamingResponser7   s    r9   Úwith_streaming_responseÚEvents.with_streaming_response2   s   € ô +¨4Ó0Ð0r<   N©Úcreated_at_gtÚcreated_at_gteÚcreated_at_ltÚcreated_at_lteÚlimitÚorderÚpageÚtypesÚbetasÚworkspace_idÚextra_headersÚextra_queryÚ
extra_bodyÚtimeoutc               ó†  • U(       d  [        SU< 35      e0 [        [        U
5      (       a#  SR                  [	        S U
 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        [           [        UUUUUUUUUUUU	S	.S
9[        [        [        5      S9$ )á   
List Events

Args:
  created_at_gt: Return events created after this time (exclusive). Compared against the event's
      `processed_at` value.

  created_at_gte: Return events created at or after this time (inclusive). Compared against the
      event's `processed_at` value.

  created_at_lt: Return events created before this time (exclusive). Compared against the event's
      `processed_at` value.

  created_at_lte: Return events created at or before this time (inclusive). Compared against the
      event's `processed_at` value.

  order: Sort direction for results, ordered by the event's `processed_at`. Defaults to
      `asc` (chronological).

  page: Opaque pagination cursor from a previous response's `next_page`.

  types: Filter by event type. Values match the `type` field on returned events (for
      example, `user.message` or `agent.tool_use`). Omit to return all event types.

  betas: Optional header to specify the beta version(s) you want to use.

  workspace_id: Optional header to select the Workspace for this request. The value is a
      Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`).

      Only needed for credentials that can act on more than one Workspace. A
      credential that belongs to a specific Workspace may omit it; if sent, it must
      match that Workspace.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
ú9Expected a non-empty value for `session_id` but received Ú,c              3  ó8   #   • U  H  n[        U5      v •  M     g 7f©N©Ústr©Ú.0Úes     r9   Ú	<genexpr>ÚEvents.list.<locals>.<genexpr>~   ó   é € Ð5LÂeÀ´c¸!·f°fÂeùó   ‚úmanaged-agents-2026-04-01©úanthropic-betazanthropic-workspace-idrb   ú*/v1/sessions/{session_id}/events?beta=true©Ú
session_id©zcreated_at[gt]zcreated_at[gte]zcreated_at[lt]zcreated_at[lte]rG   rH   rI   rJ   ©rM   rN   rO   rP   Úquery©rI   ÚoptionsÚmodel)Ú
ValueErrorr   r   Újoinr   r   Ú_get_api_listr   r&   r-   r)   r	   r   ©r8   re   rC   rD   rE   rF   rG   rH   rI   rJ   rK   rL   rM   rN   rO   rP   s                   r9   ÚlistÚEvents.list;   sû   € ö| ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ×!Ñ!ÜÐFÐS]Ñ^ÜÔ =Ñ>Ü(Ø+Ø'Ø%Øà&3Ø'5Ø&3Ø'5Ø"Ø"Ø Ø"ñ	ñô  ÜÔ2óð' "ð 
ð 	
r<   ©rK   rL   rM   rN   rO   rP   c               ó@  • U(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9S	U0[        XVXxS
9[        S9$ )áÚ  
Send Events

Args:
  events: Events to send to the `session`.

  betas: Optional header to specify the beta version(s) you want to use.

  workspace_id: Optional header to select the Workspace for this request. The value is a
      Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`).

      Only needed for credentials that can act on more than one Workspace. A
      credential that belongs to a specific Workspace may omit it; if sent, it must
      match that Workspace.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
rS   rT   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7frV   rW   rY   s     r9   r\   ÚEvents.send.<locals>.<genexpr>É   r^   r_   r`   ra   rb   rc   rd   Úevents©rM   rN   rO   rP   ©Úbodyrj   Úcast_to©
rl   r   r   rm   r   r   Ú_postr   r)   r.   ©	r8   re   rw   rK   rL   rM   rN   rO   rP   s	            r9   ÚsendÚEvents.sendŸ   sÊ   € öJ ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ�z‰zÜÐFÐS]Ñ^Ø˜FÐ#Ü(Ø+ÐQ[ñô 7ð ð 
ð 	
r<   ©Úevent_deltasrK   rL   rM   rN   rO   rP   c               óz  • U(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        UUUUS	U0S
9[        [        [        5      S[        [           S9$ )õª  
Stream Events

Args:
  event_deltas: When set, this connection also receives streaming deltas (`event_start`,
      `event_delta`) while an event is being produced, before the event itself
      arrives. Deltas are best-effort; when the final event is produced it carries the
      complete content. A model request that ends early (an error or interrupt)
      produces no final event â€” its terminal `span.model_request_end` closes the
      preview. Accepts one or more event types to preview and may be repeated:
      `agent.message` streams `content_delta` fragments; `agent.thinking` is
      start-only â€” a signal that the agent has begun extended thinking, concluded by
      the `agent.thinking` event itself. Only previews of the requested event types
      are sent.

  betas: Optional header to specify the beta version(s) you want to use.

  workspace_id: Optional header to select the Workspace for this request. The value is a
      Workspace ID (for example, `wrkspc_011CZkZaBF1tNoB5wlCeusgy`).

      Only needed for credentials that can act on more than one Workspace. A
      credential that belongs to a specific Workspace may omit it; if sent, it must
      match that Workspace.

  extra_headers: Send extra headers

  extra_query: Add additional query parameters to the request

  extra_body: Add additional JSON properties to the request

  timeout: Override the client-level default timeout for this request, in seconds
rS   rT   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7frV   rW   rY   s     r9   r\   Ú Events.stream.<locals>.<genexpr>  r^   r_   r`   ra   rb   ú1/v1/sessions/{session_id}/events/stream?beta=truerd   r‚   rg   T©rj   r{   ÚstreamÚ
stream_cls)rl   r   r   rm   r   r   Ú_getr   r)   r	   r   r/   r$   ©	r8   re   r‚   rK   rL   rM   rN   rO   rP   s	            r9   r‰   ÚEvents.streamÛ   sé   € ö\ ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ�y‰yÜÐMÐZdÑeÜ(Ø+Ø'Ø%ØØ% |Ð4ñô ÜÔ9óð ÜÔBÑCð ð 
ð 	
r<   © )Úreturnr6   )r�   r?   ) re   rX   rC   úUnion[str, datetime] | OmitrD   r�   rE   r�   rF   r�   rG   ú
int | OmitrH   úLiteral['asc', 'desc'] | OmitrI   ú
str | OmitrJ   úSequenceNotStr[str] | OmitrK   úList[AnthropicBetaParam] | OmitrL   r“   rM   úHeaders | NonerN   úQuery | NonerO   úBody | NonerP   ú(float | httpx2.Timeout | None | NotGivenr�   z-SyncPageCursor[BetaManagedAgentsSessionEvent]©re   rX   rw   z&Iterable[BetaManagedAgentsEventParams]rK   r•   rL   r“   rM   r–   rN   r—   rO   r˜   rP   r™   r�   r.   )re   rX   r‚   ú'List[BetaManagedAgentsDeltaType] | OmitrK   r•   rL   r“   rM   r–   rN   r—   rO   r˜   rP   r™   r�   z,Stream[BetaManagedAgentsStreamSessionEvents])Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r:   r@   r   r   rp   r   r‰   Ú__static_attributes__rŽ   r<   r9   r0   r0   '   s  † Øó+ó ð+ð ó1ó ð1ð 6:Ø6:Ø59Ø6:Ø Ø/3ØØ,0Ø15Ø#'ð )-Ø$(Ø"&Ø<Eñ'b
àðb
ð 3ð	b
ð
 4ðb
ð 3ðb
ð 4ðb
ð ðb
ð -ðb
ð ðb
ð *ðb
ð /ðb
ð !ðb
ð  &ð!b
ð" "ð#b
ð$  ð%b
ð& :ð'b
ð( 
7õ)b
ðR 26Ø#'ð )-Ø$(Ø"&Ø<Eñ:
àð:
ð 7ð	:
ð
 /ð:
ð !ð:
ð &ð:
ð "ð:
ð  ð:
ð :ð:
ð 
,õ:
ð@ AEØ15Ø#'ð )-Ø$(Ø"&Ø<EñJ
àðJ
ð >ð	J
ð
 /ðJ
ð !ðJ
ð &ðJ
ð "ðJ
ð  ðJ
ð :ðJ
ð 
6÷J
ð J
r<   c                  óP  • \ rS rSr\SS j5       r\SS j5       r\\\\\\\\\\SSS\S.                               SS jjr	\\SSS\S.                 SS jjr
\\\SSS\S	.                 SS
 jjr\SSS.           SS jjrSrg)r1   i(  c                ó   • [        U 5      $ r5   )ÚAsyncEventsWithRawResponser7   s    r9   r:   ÚAsyncEvents.with_raw_response)  s   € ô *¨$Ó/Ð/r<   c                ó   • [        U 5      $ r>   )Ú AsyncEventsWithStreamingResponser7   s    r9   r@   Ú#AsyncEvents.with_streaming_response3  s   € ô 0°Ó5Ð5r<   NrB   c               ó†  • U(       d  [        SU< 35      e0 [        [        U
5      (       a#  SR                  [	        S U
 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        [           [        UUUUUUUUUUUU	S	.S
9[        [        [        5      S9$ )rR   rS   rT   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7frV   rW   rY   s     r9   r\   Ú#AsyncEvents.list.<locals>.<genexpr>  r^   r_   r`   ra   rb   rc   rd   rf   rg   ri   )rl   r   r   rm   r   r   rn   r   r'   r-   r)   r	   r   ro   s                   r9   rp   ÚAsyncEvents.list<  sû   € ö| ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ×!Ñ!ÜÐFÐS]Ñ^Ü Ô!>Ñ?Ü(Ø+Ø'Ø%Øà&3Ø'5Ø&3Ø'5Ø"Ø"Ø Ø"ñ	ñô  ÜÔ2óð' "ð 
ð 	
r<   rr   c             ƒ  ó\  #   • U(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9S	U0[        XVXxS
9[        S9I Sh  v•N $  N7f)rt   rS   rT   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7frV   rW   rY   s     r9   r\   Ú#AsyncEvents.send.<locals>.<genexpr>Ê  r^   r_   r`   ra   rb   rc   rd   rw   rx   ry   Nr|   r~   s	            r9   r   ÚAsyncEvents.send   s×   é € öJ ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ—Z‘ZÜÐFÐS]Ñ^Ø˜FÐ#Ü(Ø+ÐQ[ñô 7ð  ð 
÷ 
ð 	
ñ 
ùs   ‚B#B,Â%B*Â&B,r�   c             ƒ  ó–  #   • U(       d  [        SU< 35      e0 [        [        U5      (       a#  SR                  [	        S U 5       S/5      5      O[
        US.5      EU=(       d    0 EnSS0U=(       d    0 EnU R                  [        SUS9[        UUUUS	U0S
9[        [        [        5      S[        [           S9I Sh  v•N $  N7f)r„   rS   rT   c              3  ó8   #   • U  H  n[        U5      v •  M     g 7frV   rW   rY   s     r9   r\   Ú%AsyncEvents.stream.<locals>.<genexpr>  r^   r_   r`   ra   rb   r‡   rd   r‚   rg   Trˆ   N)rl   r   r   rm   r   r   r‹   r   r)   r	   r   r/   r%   rŒ   s	            r9   r‰   ÚAsyncEvents.streamÜ  sö   é € ö\ ÜÐXÐYcÑXfÐgÓhÐhð

Üô   —‘ð '*§h¡h¬uÑ5LÁeÓ5LÐOjÐNkÓ/lÔ&mä"Ø.:ñ	óð

ð ×" ð

ˆð *Ð+FÐ`È=×K^Ð\^Ð`ˆØ—Y‘YÜÐMÐZdÑeÜ(Ø+Ø'Ø%ØØ% |Ð4ñô ÜÔ9óð Ü"Ô#GÑHð ð 
÷ 
ð 	
ñ 
ùs   ‚C C	ÃCÃC	)Úmax_idleÚenvironment_keyrM   c          	     ót   • SSK JnJn  [        U5      (       d  UnU" [	        SU R
                  5      UUUUUS9$ )u¿  Dispatch a self-hosted session's tool-call events.

The sessions-side counterpart to `client.beta.messages.tool_runner`:
returns a `anthropic.lib.environments.SessionToolRunner` â€” an
async iterable that attaches to the session's event stream, reconciles
against the events-list endpoint, runs the matching tool from `tools`
for each tool-call event, posts the matching result event back, and
yields one `anthropic.lib.environments.DispatchedToolCall` per
completed call. It handles both tool-call kinds: `agent.tool_use`
(built-in agent-toolset tools) answered with `user.tool_result`, and
`agent.custom_tool_use` (custom, user-defined tools) answered with
`user.custom_tool_result`. A call the server gated behind user
confirmation (`evaluated_permission` `ask`, e.g. a tool configured
with the `always_ask` permission policy) is held until the matching
`user.tool_confirmation` event arrives â€” executed on `allow`,
never executed on `deny` (the denied call is still yielded with
`confirmation="deny"` so it can be observed). Internally drives
event-stream reconnect (with capped backoff) via an anyio task group
so it works under both `asyncio` and `trio`.

Iteration ends when the session terminates (`session.status_terminated`
/ `session.deleted`), when the consumer breaks out of the loop, or â€”
once the session has gone idle with `stop_reason` `end_turn` â€”
`max_idle` seconds elapse with no new event (any new event resets that
countdown; it re-arms on the next `end_turn` idle). `max_idle=None`
disables that last condition. It does **not** touch the work-item lease â€”
wrap it in an `anthropic.lib.environments.EnvironmentWorker` if
you need heartbeating / force-stop.

Usage:

```py
from anthropic.lib.tools.agent_toolset import AgentToolContext, beta_agent_toolset_20260401

async with AgentToolContext(workdir=...) as env:
    async for call in client.beta.sessions.events.tool_runner(
        work.data.id,
        tools=[*beta_agent_toolset_20260401(env), my_tool],
    ):
        ...
```

Args:
  session_id: The session whose events stream we attach to. Passed
    positionally, matching `list` / `send` / `stream` on this
    resource.
  tools: Registry of tool callables the runner will execute when the
    agent emits matching `agent.tool_use` / `agent.custom_tool_use`
    events â€” the same `anthropic.lib.tools.BetaAsyncFunctionTool`
    shape `client.beta.messages.tool_runner` accepts.
  max_idle: Seconds to keep running after the session goes idle with
    `stop_reason` `end_turn` before stopping; any new event resets
    the countdown. Defaults to `DEFAULT_MAX_IDLE` (60s) when not
    given. `None` disables it.
  environment_key: The self-hosted environment key. When set, the
    runner builds a Bearer-only scoped sub-client keyed to that
    environment for the event stream / list / send calls; leave it
    unset to authenticate those calls with the parent client's own
    credentials.
  extra_headers: Optional headers passed through per request on every
    call the runner makes (event stream / list / send). They are
    threaded into each call's `extra_headers=` and never assigned
    onto the client, so client state is not mutated. Auth and
    `x-stainless-helper` are supplied by the runner's scoped
    sub-client (and the parent client's `default_headers` propagate
    via its `client.copy()`); a header given here overrides the
    scoped client's same-named default for that request, so use it for
    caller passthrough (e.g. trace ids), not to set auth.
r   )ÚDEFAULT_MAX_IDLEr   r   )Útoolsr´   rµ   rM   )Úlib.tools._beta_session_runnerr·   r   r   r	   Ú_client)r8   re   r¸   r´   rµ   rM   r·   r   s           r9   Útool_runnerÚAsyncEvents.tool_runner(  sD   € ÷b 	[ä˜×!Ñ!Ø'ˆHá ÜÐ! 4§<¡<Ó0ØØØØ+Ø'ñ
ð 	
r<   rŽ   )r�   r£   )r�   r¦   ) re   rX   rC   r�   rD   r�   rE   r�   rF   r�   rG   r‘   rH   r’   rI   r“   rJ   r”   rK   r•   rL   r“   rM   r–   rN   r—   rO   r˜   rP   r™   r�   z]AsyncPaginator[BetaManagedAgentsSessionEvent, AsyncPageCursor[BetaManagedAgentsSessionEvent]]rš   )re   rX   r‚   r›   rK   r•   rL   r“   rM   r–   rN   r—   rO   r˜   rP   r™   r�   z1AsyncStream[BetaManagedAgentsStreamSessionEvents])re   rX   r¸   zSequence[BetaAnyRunnableTool]r´   zfloat | None | NotGivenrµ   z
str | NonerM   r–   r�   r   )rœ   r�   rž   rŸ   r   r:   r@   r   r   rp   r   r‰   r»   r    rŽ   r<   r9   r1   r1   (  sZ  † Øó0ó ð0ð ó6ó ð6ð 6:Ø6:Ø59Ø6:Ø Ø/3ØØ,0Ø15Ø#'ð )-Ø$(Ø"&Ø<Eñ'b
àðb
ð 3ð	b
ð
 4ðb
ð 3ðb
ð 4ðb
ð ðb
ð -ðb
ð ðb
ð *ðb
ð /ðb
ð !ðb
ð  &ð!b
ð" "ð#b
ð$  ð%b
ð& :ð'b
ð( 
gõ)b
ðR 26Ø#'ð )-Ø$(Ø"&Ø<Eñ:
àð:
ð 7ð	:
ð
 /ð:
ð !ð:
ð &ð:
ð "ð:
ð  ð:
ð :ð:
ð 
,õ:
ð@ AEØ15Ø#'ð )-Ø$(Ø"&Ø<EñJ
àðJ
ð >ð	J
ð
 /ðJ
ð !ðJ
ð &ðJ
ð "ðJ
ð  ðJ
ð :ðJ
ð 
;õJ
ðb -6Ø&*Ø(,ñ]
àð]
ð -ð	]
ð
 *ð]
ð $ð]
ð &ð]
ð 
÷]
ð ]
r<   c                  ó   • \ rS rSrSS jrSrg)r6   iˆ  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rV   )Ú_eventsr    rp   r   r‰   ©r8   rw   s     r9   Ú__init__ÚEventsWithRawResponse.__init__‰  sD   € ØŒä+Ø�K‰Kó
ˆŒ	ô ,Ø�K‰Kó
ˆŒ	ô .Ø�M‰Mó
ˆ�r<   ©r¿   rp   r   r‰   N©rw   r0   r�   ÚNone©rœ   r�   rž   rŸ   rÁ   r    rŽ   r<   r9   r6   r6   ˆ  ó   † ÷
r<   r6   c                  ó   • \ rS rSrSS jrSrg)r£   i—  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rV   )r¿   r"   rp   r   r‰   rÀ   s     r9   rÁ   Ú#AsyncEventsWithRawResponse.__init__˜  sD   € ØŒä1Ø�K‰Kó
ˆŒ	ô 2Ø�K‰Kó
ˆŒ	ô 4Ø�M‰Mó
ˆ�r<   rÃ   N©rw   r1   r�   rÅ   rÆ   rŽ   r<   r9   r£   r£   —  rÇ   r<   r£   c                  ó   • \ rS rSrSS jrSrg)r?   i¦  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rV   )r¿   r!   rp   r   r‰   rÀ   s     r9   rÁ   Ú$EventsWithStreamingResponse.__init__§  sD   € ØŒä0Ø�K‰Kó
ˆŒ	ô 1Ø�K‰Kó
ˆŒ	ô 3Ø�M‰Mó
ˆ�r<   rÃ   NrÄ   rÆ   rŽ   r<   r9   r?   r?   ¦  rÇ   r<   r?   c                  ó   • \ rS rSrSS jrSrg)r¦   iµ  c                ó¬   • Xl         [        UR                  5      U l        [        UR                  5      U l        [        UR                  5      U l        g rV   )r¿   r#   rp   r   r‰   rÀ   s     r9   rÁ   Ú)AsyncEventsWithStreamingResponse.__init__¶  sD   € ØŒä6Ø�K‰Kó
ˆŒ	ô 7Ø�K‰Kó
ˆŒ	ô 9Ø�M‰Mó
ˆ�r<   rÃ   NrË   rÆ   rŽ   r<   r9   r¦   r¦   µ  rÇ   r<   r¦   )IÚ
__future__r   Útypingr   r   r   r   r   r	   r
   Ú	itertoolsr   Útyping_extensionsr   Úhttpx2Úcollections.abcr   rº   r   r¹   r   r   Ú_typesr   r   r   r   r   r   r   r   Ú_utilsr   r   r   Ú_compatr   Ú	_resourcer   r   Ú	_responser    r!   r"   r#   Ú
_streamingr$   r%   Ú
paginationr&   r'   Ú_base_clientr(   r)   Útypes.anthropic_beta_paramr*   Ú)types.beta.beta_managed_agents_delta_typer+   Ú4types.beta.sessions.beta_managed_agents_event_paramsr,   Ú5types.beta.sessions.beta_managed_agents_session_eventr-   Ú;types.beta.sessions.beta_managed_agents_send_session_eventsr.   Ú=types.beta.sessions.beta_managed_agents_stream_session_eventsr/   Ú__all__r0   r1   r6   r£   r?   r¦   rŽ   r<   r9   Ú<module>rç      s³   ðÝ "ç B× BÝ Ý Ý %ã æÝ(å*ßYç \× \Ó \ß ?Ñ ?Ý 'ß ;÷ó ÷ /ß :ß AÝ =Ý TÝ aÝ cÝ nÝ rà�]Ð
#€ô~
ˆ_ô ~
ôB]
Ð"ô ]
÷@
ñ 
÷
ñ 
÷
ñ 
÷
ò 
r<   