ޠjPSrSSKJr SSKJrJr SSKJr SSKJ r "SS5r g) 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) AsyncIteratorIterator)Any) StreamChannelc\rSrSrSrSSSjjr\SSj5rSSjrSSjr SSjr SS jr SS jr SS jr SS jrS rg)ToolCallStreamuScoped 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. NcpXlX lX0l[5UlSUlSUlSUlg)zInitialize 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) tool_call_id tool_nameinputr_output_deltasoutputerror completed)selfr r rs ^/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph/prebuilt/_tool_call_stream.py__init__ToolCallStream.__init__%s3)" 2?/ !% cUR$)zThe 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. )rrs r output_deltasToolCallStream.output_deltas;s"""rc6URRUS9 g)zBind the deltas log to sync or async iteration. Called by `ToolCallTransformer` when constructing this handle so the log matches the enclosing mux's mode. )is_asyncN)r_bind)rrs rrToolCallStream._bindEs !!8!4rc:URRU5 gN)rpush)rdeltas r _push_deltaToolCallStream._push_deltaMs   'rcRXlSUlURR5 gNT)rrrclose)rrs r_finishToolCallStream._finishPs   !!#rcRXlSUlURR5 gr')rrrr()rmessages r_failToolCallStream._failUs   !!#rc,[UR5$)zIterate delta chunks synchronously. Equivalent to `iter(self.output_deltas)`. Raises `TypeError` if the underlying log is bound to async mode. )iterrrs r__iter__ToolCallStream.__iter__Zs D''((rc6URR5$)zIterate delta chunks asynchronously. Equivalent to `aiter(self.output_deltas)`. Raises `TypeError` if the underlying log is bound to sync mode. )r __aiter__rs rr4ToolCallStream.__aiter__bs "",,..rcUR(aURcSOUR(aSOSnSUR<SUR<SUS3$)NrfailedrunningzToolCallStream(tool_call_id=z , tool_name=z , status=))rrr r )rstatuss r__repr__ToolCallStream.__repr__jsa~~$**"4 ~~ +4+<+<*?@*)F81 > r)rrrrrr r r!)r strr r=rzdict[str, Any] | NonereturnNone)r>zStreamChannel[Any])rboolr>r?)r#rr>r?)rrr>r?)r,r=r>r?)r>z Iterator[Any])r>zAsyncIterator[Any])r>r=)__name__ __module__ __qualname____firstlineno____doc__rpropertyrrr$r)r-r1r4r;__static_attributes__rrr r sn.(, %   ,##5($ $ )/  rr N) rE __future__rcollections.abcrrtypingrlanggraph.stream.stream_channelrr rHrrrMs$#39d d r