LangChain Reference home page

GitHub
Main Docs

Deep Agents

LangGraph Checkpoint

LangGraph Store

Checkpoint Postgres

Store Postgres

Checkpoint SQLite

LangGraph Prebuilt

LangGraph CLI

LangGraph SDK

LangGraph Supervisor

LangGraph Swarm

⌘I

LangChain Assistant

Ask a question to get started

Enter to send•Shift+Enter new line

SyncThreadStream

Copy

SyncThreadStream(
  self,
  *,
  http: SyncHttpClient,
  thread_id: str,
  assistant_id: str

Constructors

Attributes

Methods

View source on GitHub

headers

Mapping

[

str

]

None

run_start_timeout

float

None

explicit_thread_id

bool

False

transport_kind

Literal

[

'sse'

'websocket'

]

'sse'

)

constructor

__init__

Name	Type
http	SyncHttpClient
thread_id	str
assistant_id	str
headers	Mapping[str, str] \| None
run_start_timeout	float \| None
explicit_thread_id	bool
transport_kind	Literal['sse', 'websocket']

attribute

thread_id: thread_id

attribute

assistant_id: assistant_id

attribute

interrupted: bool

attribute

interrupts: list[InterruptPayload]

Fetch terminal thread state (blocking); waits for lifecycle completion.

attribute

events: Iterator[Event]

Raw iterator of every Event the server emits for this thread.

method

Tear down the thread stream. Idempotent.

method

Open a typed subscription against the shared SSE.

Returns an iterator that yields raw Event dicts matching the given filter. Multiple concurrent subscribes share one HTTP connection whose union expands or rotates as subscriptions come and go.

Synchronous context manager for one thread's v3 streaming session.

Construct via client.threads.stream(thread_id=None, *, assistant_id, ...) rather than instantiating directly.

Menu

SyncThreadStream

Constructors

Attributes

Methods