Struct AssistantMessageEventStreamProducer 

pub struct AssistantMessageEventStreamProducer { /* private fields */ }

The producer side. Mirrors the TS pusher: push(ev) until a terminal event, at which point the result oneshot is fulfilled (first terminal wins; push after a terminal event is a no-op matching if (this.done) return).

Implementations

impl AssistantMessageEventStreamProducer

pub fn push(&mut self, event: AssistantMessageEvent) -> bool

Push an event. Returns false if the consumer has dropped the stream (back-pressure / cancellation). After a terminal Done/Error is pushed, further push calls are no-ops returning true (the stream is “done” but alive), mirroring TS push semantics. The terminal event itself is always delivered (so the consumer sees it) before the flag takes effect.

pub fn is_done(&self) -> bool

pub fn close(self)

Drop the producer without delivering a terminal event. The consumer’s next() returns None and result() yields RecvError. Providers should push Error instead of relying on this; it exists for the “producer task panicked” safety net.