Public exports for the v3 streaming transport layer.
Convert an HTTP base URL plus API path into a WebSocket URL.
Protocol implemented by async SSE and WebSocket transports.
Handle for one async filtered event stream.
Handle for one sync filtered event stream.
Protocol implemented by sync SSE and WebSocket transports.
v3 protocol transport bound to a single thread_id.
Commands go to POST /threads/{thread_id}/commands (JSON in, JSON out).
open_event_stream opens filtered SSE streams against
POST /threads/{thread_id}/stream/events.
Sync v3 protocol transport bound to one thread id.
Sync v3 protocol transport using HTTP commands and WebSocket events.
v3 protocol transport using HTTP commands and WebSocket events.
Synchronous HTTP/SSE transport for the v3 thread-centric protocol.
Async WebSocket transport for the v3 thread-centric protocol.
HTTP/SSE transport for the v3 thread-centric protocol.
Direct port of libs/sdk/src/client/stream/transport/http.ts.
ProtocolSseTransport is bound to a single thread_id at construction. Commands
go to POST /threads/{thread_id}/commands (JSON in, JSON out). Each
open_event_stream(params) opens an independent filtered SSE connection at
POST /threads/{thread_id}/stream/events with the SubscribeParams in the
request body.
Sync WebSocket transport for the v3 thread-centric protocol.
Shared transport contracts for v3 thread-centric streaming.