Enum PlexusStreamItem 

pub enum PlexusStreamItem {
    Data {
        metadata: StreamMetadata,
        content_type: String,
        content: Value,
    },
    Progress {
        metadata: StreamMetadata,
        message: String,
        percentage: Option<f32>,
    },
    Error {
        metadata: StreamMetadata,
        message: String,
        code: Option<String>,
        recoverable: bool,
    },
    Request {
        request_id: String,
        request_data: Value,
        timeout_ms: u64,
    },
    Done {
        metadata: StreamMetadata,
    },
}

Universal stream item - all activations emit this type

The caller (DynamicHub routing layer) wraps activation responses with metadata. This is the only type that crosses the wire.

Variants

Data

Data payload with caller-applied metadata

Fields

metadata: StreamMetadata

Metadata from calling layer

content_type: String

Type identifier for deserialization (e.g., “health.status”)

content: Value

The actual payload (serialized activation event)

Progress

Progress update during long-running operations

Fields

metadata: StreamMetadata

Metadata from calling layer

message: String

Human-readable progress message

percentage: Option<f32>

Optional completion percentage (0.0 - 100.0)

Error

Error occurred during processing

Fields

metadata: StreamMetadata

Metadata from calling layer

message: String

Human-readable error message

code: Option<String>

Optional error code for programmatic handling

recoverable: bool

Whether the operation can be retried

Request

Bidirectional request from server to client

Server can ask client for input during stream execution. Client must respond via transport-specific mechanism (MCP: _plexus_respond tool, WebSocket: plexus.respond RPC).

Fields

request_id: String

Unique identifier for correlating response

request_data: Value

Serialized request data (generic Req type)

timeout_ms: u64

Maximum time to wait for response (milliseconds)

Done

Stream completed successfully

Fields

metadata: StreamMetadata

Metadata from calling layer

Implementations

impl PlexusStreamItem

pub fn data( metadata: StreamMetadata, content_type: String, content: Value, ) -> PlexusStreamItem

Create a Data item

pub fn progress( metadata: StreamMetadata, message: String, percentage: Option<f32>, ) -> PlexusStreamItem

Create a Progress item

pub fn error( metadata: StreamMetadata, message: String, code: Option<String>, recoverable: bool, ) -> PlexusStreamItem

Create an Error item

pub fn request( request_id: String, request_data: Value, timeout_ms: u64, ) -> PlexusStreamItem

Create a Request item

pub fn done(metadata: StreamMetadata) -> PlexusStreamItem

Create a Done item

pub fn metadata(&self) -> Option<&StreamMetadata>

Get the metadata from any stream item variant (if available)

Note: Request items don’t have metadata as they’re server-initiated

Trait Implementations

impl Clone for PlexusStreamItem

fn clone(&self) -> PlexusStreamItem

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PlexusStreamItem

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PlexusStreamItem

fn deserialize<__D>( __deserializer: __D, ) -> Result<PlexusStreamItem, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for PlexusStreamItem

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for PlexusStreamItem

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.