Skip to content

Add typed workflow stream subscriptions - #3080

Open
brianstrauch wants to merge 1 commit into
amazzeo/transfer-type-convertersfrom
codex/workflow-stream-typed-subscriptions-v2
Open

brianstrauch wants to merge 1 commit into
amazzeo/transfer-type-convertersfrom
codex/workflow-stream-typed-subscriptions-v2

Conversation

@brianstrauch

Copy link
Copy Markdown
Member

What changed?

  • Added typed workflow stream topic handles, subscriptions, listeners, and items.
  • Added Class<T> and Type subscription overloads that decode items before delivery.
  • Preserved raw Payload subscriptions as an escape hatch and retained raw payload access on typed items.
  • Added typed workflow-side topic handles and named publishPayload methods.
  • Added coverage for transfer converters, parameterized types, multiple typed views, listener and iterator conversion failures, and payload codecs.
  • Updated the workflow streams documentation.

Why?

Transfer Type Converters need the requested language-level type when decoding. Moving that type information into subscriptions avoids requiring consumers to reconstruct an internal codec-free data converter or use a Java-specific decodeItem helper.

Breaking changes?

This changes the experimental workflow streams API introduced by the base PR. The stream item, subscription, listener, and topic handle types are now generic, and the temporary WorkflowStreamClient.decodeItem API is removed. Existing raw method descriptors remain compatible through type erasure.

Server PR

None.

Testing

  • ./gradlew --offline :temporal-workflowstreams:spotlessApply :temporal-workflowstreams:test
  • ./gradlew --offline :temporal-workflowstreams:javadoc

@brianstrauch
brianstrauch requested review from a team as code owners September 16, 2026 19:41
@brianstrauch
brianstrauch requested a balanced review from Copilot September 16, 2026 19:42

Copilot AI left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Copilot was unable to review this pull request because the user who requested the review has reached their quota limit.

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.

2 participants