Table of Contents

Namespace Temporalio.Extensions.WorkflowStreams

Classes

FlushTimeoutException

Exception thrown when an ambiguously delivered publish batch exceeds its retry duration.

WorkflowStream

A durable, offset-addressed, multi-topic log hosted inside a Temporal workflow.

WorkflowStreamClient

External publisher and subscriber for a workflow-hosted stream.

WorkflowStreamClientOptions

Options for constructing a WorkflowStreamClient.

WorkflowStreamClientTopicHandle

A client-side handle bound to one topic.

WorkflowStreamClientTopicHandle<T>

A strongly typed client-side handle bound to one topic.

WorkflowStreamConstants

Fixed handler names and application-failure types in the Workflow Streams wire protocol.

WorkflowStreamItem

A decoded item yielded by a Workflow Streams subscription.

WorkflowStreamItem<T>

A decoded, strongly typed Workflow Streams subscription item.

WorkflowStreamOptions

Options for constructing a workflow-side stream.

WorkflowStreamState

Serializable Workflow Streams state for continue-as-new.

WorkflowStreamSubscribeOptions

Options for a Workflow Streams subscription.

WorkflowStreamTopicHandle

A workflow-side handle bound to one topic.

WorkflowStreamTopicHandle<T>

A strongly typed workflow-side handle bound to one topic.

WorkflowStreamWireItem

A stream item in the cross-language JSON envelope.