feat: add general-purpose WebSocket client for real-time event consumption#236

Draft

aliev wants to merge 30 commits intomainfrom

feat/websocket-support

Commits on Apr 10, 2026

feat: scaffold StreamWS class for general-purpose WebSocket support
aliev
committed
feat: add WS URL construction with scheme replacement and query params
aliev
committed
feat: implement WS connect/disconnect with auth handshake
aliev
committed
feat: add background reader task to dispatch events to listeners
aliev
committed
feat: add heartbeat loop to detect stale connections
aliev
committed
feat: auto-reconnect with exponential backoff and jitter
aliev
committed
feat: refresh token on error code 40 during reconnect
aliev
committed
feat: add AsyncStream.connect_ws() for convenient WS lifecycle management
aliev
committed
chore: add [ws] optional dependency group for websockets
aliev
committed
docs: add internal README for WebSocket client usage and testing
aliev
committed
chore: update uv.lock for new [ws] optional dependency group
aliev
committed
fix: wrap health check message in array to match Stream protocol
aliev
committed
fix: reject non-connection.ok auth responses
aliev
committed
fix: don't reconnect when server closes with code 1000
aliev
committed
fix: add wsID guard to ignore stale messages from old connections
aliev
committed
fix: don't overwrite user-provided static tokens on code 40
aliev
committed
style: apply formatter to ws client and tests
aliev
committed
fix: use /api/v2/connect path for WebSocket endpoint
aliev
committed
fix: support decorator syntax for on_wildcard()
aliev
committed
fix: allow kwargs to override base_url and user_agent in connect_ws
aliev
committed
style: apply ruff format and remove unused import
aliev
committed
docs: update WS README with findings from integration testing
aliev
committed
fix: prevent leaked exceptions in reconnect and disconnect cleanup
aliev
committed
fix: prevent reconnect from cancelling itself via _cancel_tasks
aliev
committed
fix: clean up stale tasks on connect and guard emit from listener errors
aliev
committed
fix: prevent duplicate reconnect tasks and socket leaks on auth failure
aliev
committed
refactor: reuse BASE_URL from getstream.stream instead of duplicating
aliev
committed
refactor: extract _close_websocket helper to deduplicate socket cleanup
aliev
committed
refactor: use urlparse/urlunparse for WS URL construction
aliev
committed

Commits on Apr 12, 2026

fix: prevent StreamWS leak on connect failure and prune stale connections
aliev
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: add general-purpose WebSocket client for real-time event consumption#236

feat: add general-purpose WebSocket client for real-time event consumption#236
aliev wants to merge 30 commits intomainfrom
feat/websocket-support

Commits on Apr 10, 2026

feat: scaffold StreamWS class for general-purpose WebSocket support

feat: add WS URL construction with scheme replacement and query params

feat: implement WS connect/disconnect with auth handshake

feat: add background reader task to dispatch events to listeners

feat: add heartbeat loop to detect stale connections

feat: auto-reconnect with exponential backoff and jitter

feat: refresh token on error code 40 during reconnect

feat: add AsyncStream.connect_ws() for convenient WS lifecycle management

chore: add [ws] optional dependency group for websockets

docs: add internal README for WebSocket client usage and testing

chore: update uv.lock for new [ws] optional dependency group

fix: wrap health check message in array to match Stream protocol

fix: reject non-connection.ok auth responses

fix: don't reconnect when server closes with code 1000

fix: add wsID guard to ignore stale messages from old connections

fix: don't overwrite user-provided static tokens on code 40

style: apply formatter to ws client and tests

fix: use /api/v2/connect path for WebSocket endpoint

fix: support decorator syntax for on_wildcard()

fix: allow kwargs to override base_url and user_agent in connect_ws

style: apply ruff format and remove unused import

docs: update WS README with findings from integration testing

fix: prevent leaked exceptions in reconnect and disconnect cleanup

fix: prevent reconnect from cancelling itself via _cancel_tasks

fix: clean up stale tasks on connect and guard emit from listener errors

fix: prevent duplicate reconnect tasks and socket leaks on auth failure

refactor: reuse BASE_URL from getstream.stream instead of duplicating

refactor: extract _close_websocket helper to deduplicate socket cleanup

refactor: use urlparse/urlunparse for WS URL construction

Commits on Apr 12, 2026

fix: prevent StreamWS leak on connect failure and prune stale connections