feat(client): Client.listen() and listChanged auto-open on modern connections by felixweinberger · Pull Request #2322 · modelcontextprotocol/typescript-sdk

feat(core): in-Protocol park primitive for the listen driver

felixweinberger

committed

feat(client): Client.listen() + McpSubscription + listChanged auto-open on modern

felixweinberger

committed

docs(examples): runnable subscriptions/listen example pair

felixweinberger

committed

test(e2e): subscriptions/listen cells

felixweinberger

committed

chore: lint/format fixes; update integration discoverRoundtrip for A11 discharge

felixweinberger

committed

docs: migration.md entry for subscriptions/listen

felixweinberger

committed

fix(client): guard listen() connectivity before park; auto-open failure surfaces via onerror

felixweinberger

committed

refactor(client): centralize per-connection state reset

felixweinberger

committed

refactor(client): listen() driver as an explicit opening→open→closed state machine

felixweinberger

committed

fix(client): derive auto-open listen filter from configured ∩ server-advertised

felixweinberger

committed

fix(client): McpSubscription.close() is transport-agnostic — always abort + send notifications/cancelled

felixweinberger

committed

fix(client): per-request abort in StreamableHTTP is a clean shutdown — no onerror, no reconnect

felixweinberger

committed

fix(client): feature-detect AbortSignal.any (Node >=20 floor includes 20.0–20.2)

felixweinberger

committed

fix(client): settle() drops _listenState by the captured id, not via parked

felixweinberger

committed

fix(client): listen() honors RequestOptions.signal

felixweinberger

committed

docs: auto-open listen filter is configured ∩ server-advertised everywhere

felixweinberger

committed

fix(client): listChanged config is durable (read fresh per connect, never consumed); align close() prose

felixweinberger

committed

fix(client): pass through unmatched listen acks; reword server-cancel error

felixweinberger

committed

fix(client): settle live listen state on connection reset; reset even when transport close rejects

felixweinberger

committed

test(client): cover the listen() state machine's termination paths

felixweinberger

committed

test(e2e): subscriptions/listen honored filter narrows against advertised capabilities

felixweinberger

committed

fix(client): listen auto-open inherits only ack timeout; thread requestSignal through SSE reconnect; anySignal fallback removes sibling listener

felixweinberger

committed

feat(client): McpSubscription.closed observes termination cause; reset clears debounce timers

felixweinberger

committed

fix(client): listen polish — derived ack-wait signal; envelope on listen-cancel; intentional-abort guards across reconnect path; typed result-during-opening

felixweinberger

committed

refactor(client): listen() driver is transport-level — drop the in-Protocol park primitive

felixweinberger

committed

fix(client): close transport when connect-signal aborts during auto-open ack wait; drop old-layout listen examples (live in #2325); e2e CLAUDE.md doc nit

felixweinberger

committed

fix(client): fire onRequestStreamEnd on the GET-resume 405/null-body terminal; skip auto-open when handler registration throws; await transport close on connect-abort during the auto-open ack wait;…

felixweinberger

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat(client): Client.listen() and listChanged auto-open on modern connections - #2322

feat(client): Client.listen() and listChanged auto-open on modern connections#2322
felixweinberger merged 27 commits into
v2-2026-07-28from
fweinberger/listen-client

Commits on Jun 18, 2026

feat(core): in-Protocol park primitive for the listen driver

feat(client): Client.listen() + McpSubscription + listChanged auto-open on modern

docs(examples): runnable subscriptions/listen example pair

test(e2e): subscriptions/listen cells

chore: lint/format fixes; update integration discoverRoundtrip for A11 discharge

docs: migration.md entry for subscriptions/listen

fix(client): guard listen() connectivity before park; auto-open failure surfaces via onerror

refactor(client): centralize per-connection state reset

refactor(client): listen() driver as an explicit opening→open→closed state machine

fix(client): derive auto-open listen filter from configured ∩ server-advertised

fix(client): McpSubscription.close() is transport-agnostic — always abort + send notifications/cancelled

fix(client): per-request abort in StreamableHTTP is a clean shutdown — no onerror, no reconnect

fix(client): feature-detect AbortSignal.any (Node >=20 floor includes 20.0–20.2)

fix(client): settle() drops _listenState by the captured id, not via parked

fix(client): listen() honors RequestOptions.signal

docs: auto-open listen filter is configured ∩ server-advertised everywhere

fix(client): listChanged config is durable (read fresh per connect, never consumed); align close() prose

fix(client): pass through unmatched listen acks; reword server-cancel error

fix(client): settle live listen state on connection reset; reset even when transport close rejects

test(client): cover the listen() state machine's termination paths

test(e2e): subscriptions/listen honored filter narrows against advertised capabilities

fix(client): listen auto-open inherits only ack timeout; thread requestSignal through SSE reconnect; anySignal fallback removes sibling listener

feat(client): McpSubscription.closed observes termination cause; reset clears debounce timers

fix(client): listen polish — derived ack-wait signal; envelope on listen-cancel; intentional-abort guards across reconnect path; typed result-during-opening

refactor(client): listen() driver is transport-level — drop the in-Protocol park primitive

fix(client): close transport when connect-signal aborts during auto-open ack wait; drop old-layout listen examples (live in #2325); e2e CLAUDE.md doc nit

fix(client): fire onRequestStreamEnd on the GET-resume 405/null-body terminal; skip auto-open when handler registration throws; await transport close on connect-abort during the auto-open ack wait;…