§ ™ŠtjîãóX—dZddlmZddlmZmZddlmZddlm Z Gd„d¦«Z dS) u]In-process handle for a single tool call's streaming execution. Mirrors the shape of `ChatModelStream` from langchain-core but simpler — a tool has one output channel, no content-block multiplexing. Populated by `ToolCallTransformer` as `tool-started` / `tool-output-delta` / `tool-finished` / `tool-error` events flow in on the `tools` channel. é)Ú annotations)Ú AsyncIteratorÚIterator)ÚAny)Ú StreamChannelcón—eZdZdZ ddd „Zedd „¦«Zdd„Zd d„Zd!d„Z d"d„Z d#d„Z d$d„Z d%d„Z dS)&ÚToolCallStreamuLScoped view of a single tool call's lifecycle. Yielded on `run.tool_calls` once per `tool-started` event. Fields are populated as events arrive: - `tool_call_id`, `tool_name`, `input`: stable from the start event. - `output_deltas`: a `StreamChannel` of delta chunks. Iterate (sync or async) to consume partial output in arrival order. - `output`: terminal payload from `tool-finished`, or `None` if the call failed or is still in flight. - `error`: terminal error string from `tool-error`, or `None` if the call succeeded or is still in flight. - `completed`: True once a terminal event (`tool-finished` or `tool-error`) has been observed. `ToolCallStream` is not meant to be constructed by end users — it's produced by `ToolCallTransformer` as events flow through the mux. NÚ tool_call_idÚstrÚ tool_nameÚinputúdict[str, Any] | NoneÚreturnÚNonecó€—||_||_||_t¦«|_d|_d|_d|_dS)a,Initialize a fresh handle for a tool call. Args: tool_call_id: The `tool_call_id` from the AIMessage. tool_name: The tool's name. input: The tool's input arguments (as reported by `on_tool_start`), or `None` if none were captured. NF)r r r rÚ_output_deltasÚoutputÚerrorÚ completed)Úselfr r r s úb/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph/prebuilt/_tool_call_stream.pyÚ__init__zToolCallStream.__init__%s?€ð)ˆÔØ"ˆŒØˆŒ Ý2?±/´/ˆÔ؈Œ Ø!%ˆŒ ؈ŒˆˆóúStreamChannel[Any]có—|jS)zñThe channel of streamed `tool-output-delta` payloads. Iterate (sync or async depending on how the run was started) to consume partial output in arrival order. The log closes when the tool finishes or errors. )r©rs rÚ output_deltaszToolCallStream.output_deltas;s €ðÔ"Ð"rÚis_asyncÚboolcó<—|j |¬¦«dS)z´Bind the deltas log to sync or async iteration. Called by `ToolCallTransformer` when constructing this handle so the log matches the enclosing mux's mode. )rN)rÚ_bind)rrs rr!zToolCallStream._bindEs$€ð Ô×!Ò!¨8Ð!Ñ4Ô4Ð4Ð4Ð4rÚdeltarcó:—|j |¦«dS©N)rÚpush)rr"s rÚ _push_deltazToolCallStream._push_deltaMs€Ø Ô× Ò  Ñ'Ô'Ð'Ð'Ð'rrcóT—||_d|_|j ¦«dS©NT)rrrÚclose)rrs rÚ_finishzToolCallStream._finishPs+€ØˆŒ ؈ŒØ Ô×!Ò!Ñ#Ô#Ð#Ð#Ð#rÚmessagecóT—||_d|_|j ¦«dSr()rrrr))rr+s rÚ_failzToolCallStream._failUs+€ØˆŒ ؈ŒØ Ô×!Ò!Ñ#Ô#Ð#Ð#Ð#rú Iterator[Any]có*—t|j¦«S)z¨Iterate delta chunks synchronously. Equivalent to `iter(self.output_deltas)`. Raises `TypeError` if the underlying log is bound to async mode. )Úiterrrs rÚ__iter__zToolCallStream.__iter__Zs€õ DÔ'Ñ(Ô(Ð(rúAsyncIterator[Any]có4—|j ¦«S)z©Iterate delta chunks asynchronously. Equivalent to `aiter(self.output_deltas)`. Raises `TypeError` if the underlying log is bound to sync mode. )rÚ __aiter__rs rr4zToolCallStream.__aiter__bs€ð Ô"×,Ò,Ñ.Ô.Ð.rcód—|jr |j€dn |jrdnd}d|j›d|j›d|›dS)NrÚfailedÚrunningzToolCallStream(tool_call_id=z , tool_name=z , status=ú))rrr r )rÚstatuss rÚ__repr__zToolCallStream.__repr__jso€ðŒ~ð Ø"&¤*Ð"4ð ˆKðŒ~ðàð ð >¨4Ô+<ð >ð >Øœð >ð >Ø4:ð >ð >ð >ð rr$)r r r r r rrr)rr)rrrr)r"rrr)rrrr)r+r rr)rr.)rr2)rr )Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚpropertyrr!r&r*r-r1r4r:©rrr r s耀€€€ððð.(,ð ððððð,ð#ð#ð#ñ„Xð#ð5ð5ð5ð5ð(ð(ð(ð(ð$ð$ð$ð$ð $ð$ð$ð$ð )ð)ð)ð)ð/ð/ð/ð/ð  ð  ð  ð  ð  ð  rr N) r>Ú __future__rÚcollections.abcrrÚtypingrÚlanggraph.stream.stream_channelrr r@rrúrEs›ðððð#Ð"Ð"Ð"Ð"Ð"à3Ð3Ð3Ð3Ð3Ð3Ð3Ð3ØÐÐÐÐÐà9Ð9Ð9Ð9Ð9Ð9ðd ðd ðd ðd ðd ñd ôd ðd ðd ðd r