ProtocolSseTransport

Name	Type
client	httpx.AsyncClient
thread_id	str
commands_path	str \| None
stream_path	str \| None
headers	Mapping[str, str] \| None
max_queue_size	int

open_event_stream

Open an independent filtered SSE event stream.

Posts params as a SubscribeParams body to /threads/{thread_id}/stream/events. Returns an EventStreamHandle whose events async iterator yields typed Event dicts as the server emits them. handle.ready resolves on a 2xx response (rejects on HTTP error or transport failure before headers).

Reconnect: pass params["since"] to filter outbound seqs server-side. The cursor goes in the request body, not as a Last-Event-ID header.

LangChain Assistant

Menu

Constructors

Attributes

Methods