feat: Input Streams - Bidirectional task communication#3146

Merged

ericallam merged 27 commits into

mainfrom

feature/tri-7538-input-streams-bidirectional-communication-with-running-tasks

Mar 2, 2026

Commits on Feb 28, 2026

feat: add streams.input() for inbound realtime data to running tasks

claude
authored and
ericallam
committed
refactor: connect input stream tail lazily from listener side

claude
authored and
ericallam
committed
fix: gate input stream tail connection on v2 realtime streams

claude
authored and
ericallam
committed
fix: throw error when input streams are used without v2 realtime streams

claude
authored and
ericallam
committed
docs: add input streams documentation to realtime guides

claude
authored and
ericallam
committed
docs: add API/SDK design proposal for temporal signals versioning

claude
authored and
ericallam
committed
chore: remove temporal signals versioning design doc

claude
authored and
ericallam
committed
docs: add SDK design proposal for input stream .wait() method

claude
authored and
ericallam
committed
input stream waitpoints and tests in the hello world reference project
ericallam
committed
No more input stream multiplexing, no naming collision risk, removed unnecessary waitpoint added columns.
ericallam
committed
Better span experience, show input streams on dashboard, cleanup the data format
ericallam
committed
adopt s2-lite, upgrade s2 package with support
ericallam
committed
add input streams example
ericallam
committed
better changesets
ericallam
committed
Upgrade the deployment s2 client to 0.22.5 as well and fix some typecheck issues
ericallam
committed
fix: address CodeRabbit review feedback on input streams PR
ericallam
committed
fix typecheck issue
ericallam
committed
Add result type and .unwrap() helper to inputStream.once().
ericallam
committed
small jsdocs tweak
ericallam
committed
Reconnect input stream tail after SSE timeout
ericallam
committed
automatically cleanup input stream on handlers and tail SSE requests when a task execution cleansup
ericallam
committed
remove realtime rules update, we'll do this in a separate PR
ericallam
committed
undo changes to local claude realtime skill, we'll do that in another PR
ericallam
committed
delete design doc
ericallam
committed
Add mock agentRelay example
ericallam
committed
remove unused function
ericallam
committed

Commits on Mar 1, 2026

prevent duplicate messages by reconnecting and passing in the last sequence ID
ericallam
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

feat: Input Streams - Bidirectional task communication#3146

feat: Input Streams - Bidirectional task communication#3146
ericallam merged 27 commits into
mainfrom
feature/tri-7538-input-streams-bidirectional-communication-with-running-tasks

Commits on Feb 28, 2026

feat: add streams.input() for inbound realtime data to running tasks

refactor: connect input stream tail lazily from listener side

fix: gate input stream tail connection on v2 realtime streams

fix: throw error when input streams are used without v2 realtime streams

docs: add input streams documentation to realtime guides

docs: add API/SDK design proposal for temporal signals versioning

chore: remove temporal signals versioning design doc

docs: add SDK design proposal for input stream .wait() method

input stream waitpoints and tests in the hello world reference project

No more input stream multiplexing, no naming collision risk, removed unnecessary waitpoint added columns.

Better span experience, show input streams on dashboard, cleanup the data format

adopt s2-lite, upgrade s2 package with support

add input streams example

better changesets

Upgrade the deployment s2 client to 0.22.5 as well and fix some typecheck issues

fix: address CodeRabbit review feedback on input streams PR

fix typecheck issue

Add result type and .unwrap() helper to inputStream.once().

small jsdocs tweak

Reconnect input stream tail after SSE timeout

automatically cleanup input stream on handlers and tail SSE requests when a task execution cleansup

remove realtime rules update, we'll do this in a separate PR

undo changes to local claude realtime skill, we'll do that in another PR

delete design doc

Add mock agentRelay example

remove unused function

Commits on Mar 1, 2026

prevent duplicate messages by reconnecting and passing in the last sequence ID