Skip to content

Sample code for Workflow Streams#783

Open
brianstrauch wants to merge 1 commit into
mainfrom
workflow-streams
Open

Sample code for Workflow Streams#783
brianstrauch wants to merge 1 commit into
mainfrom
workflow-streams

Conversation

@brianstrauch

Copy link
Copy Markdown
Member

What was changed

Adds a workflowstreams sample demonstrating the experimental io.temporal:temporal-workflowstreams contrib module — a durable publish/subscribe log hosted inside a Temporal workflow. Mirrors the Go and Python workflow streams samples.

Five scenarios:

  1. Basic publish/subscribe — an order workflow and its activity publish to topics; a subscriber consumes both.
  2. Reconnecting subscriber — a new client resumes from a saved offset with no gaps or duplicates.
  3. External publisher — a hub workflow hosts the stream while an external client publishes into it.
  4. Truncating ticker — bounded history via truncation; a late subscriber is fast-forwarded past truncated entries.
  5. LLM token streaming — an activity republishes streaming OpenAI token deltas, with retry/rewind handling.

Also adds a CODEOWNERS entry and a unit test.

Note: depends on the unreleased temporal-workflowstreams module, so javaSDKVersion is pinned to 1.36.0-SNAPSHOT (published locally from the workflow-streams branch of sdk-java). Do not merge until a tagged SDK release ships and the pin is dropped.

🤖 Generated with Claude Code

@brianstrauch brianstrauch requested review from a team, antmendoza and tsurdilo as code owners June 12, 2026 17:12
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant