Struct StreamSender 

pub struct StreamSender { /* private fields */ }

Sends stream events to the runtime.

Accepts Bytes, &str, String, or any serde::Serialize value (via [emit_json]).

Implementations

impl StreamSender

pub fn new(tx: Sender<Bytes>) -> Self

Create a new StreamSender backed by the given channel sender.

In typical usage this is called internally by the Caster. Exposed publicly for testing and advanced use cases.

pub fn is_ended(&self) -> bool

Whether the stream has been ended.

pub async fn emit(&self, data: Bytes) -> SdkResult<()>

Emit raw bytes.

pub async fn emit_str(&self, data: &str) -> SdkResult<()>

Emit a string (auto-encoded to UTF-8 bytes).

pub async fn emit_json<T: Serialize>(&self, data: &T) -> SdkResult<()>

Emit a serializable value as JSON bytes.

pub fn end(&self)

Signal end of stream. Idempotent — calling multiple times is safe.

Trait Implementations

impl Debug for StreamSender

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

Formats the value using the given formatter.