Struct SubscriptionEmitter 

pub struct SubscriptionEmitter { /* private fields */ }

Implementations

impl SubscriptionEmitter

pub fn emit(&self, value: UiValue) -> Result<(), AsyncRuntimeError>

Emit one value from any Rust worker thread.

Errors

Returns AsyncRuntimeError::Closed after teardown, or AsyncRuntimeError::Backpressure when a lossless stream’s bounded pending queue is full. Latest-only streams explicitly replace their pending value instead.

pub fn emit_blocking(&self, value: UiValue) -> Result<(), AsyncRuntimeError>

Emit one lossless value, waiting for foreground capacity or cancellation. Latest-only streams never block because they explicitly replace a value.

Errors

Returns when the stream closes or its shared queue is poisoned.

pub fn emit_error( &self, message: impl Into<String>, ) -> Result<(), AsyncRuntimeError>

Emit a structured error to the Rhai error callback.

Errors

Returns AsyncRuntimeError::Closed after the producer work returns, explicit cancellation, scope teardown, generation replacement, or registry drop.

pub fn close(&self)

Close the stream explicitly from the producer side.

pub fn close_reason(&self) -> Option<SubscriptionCloseReason>

Return the first reason that closed this emitter, if any.

Trait Implementations

impl Clone for SubscriptionEmitter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.