Module streaming 

Streaming helpers for the caller-wraps architecture

These functions are used by the DynamicHub routing layer to wrap activation responses with metadata. Activations return typed domain events, and the caller uses these helpers to create PlexusStreamItems.

Functions

done_stream

Create a done stream

error_stream

Create an error stream

error_stream_with_code

Create an error stream with error code

progress_stream

Create a progress stream

wrap_stream

Wrap a typed stream into PlexusStream with automatic Done event

Type Aliases

PlexusStream

Type alias for boxed stream of PlexusStreamItem