Struct ChannelEventSink 

pub struct ChannelEventSink { /* private fields */ }

Event sink backed by an async channel.

This is the default sink used internally. It connects the engine to a channel that the consumer reads from.

Backpressure

When the channel is full, send() returns an error immediately, while send_async() waits until space is available.

Implementations

impl ChannelEventSink

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

Create a new channel-backed event sink.

Trait Implementations

impl Clone for ChannelEventSink

fn clone(&self) -> ChannelEventSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EventSink for ChannelEventSink

fn send(&self, event: UiMessage) -> Result<(), SendError>

Send an event to the consumer (non-blocking).

fn send_async( &self, event: UiMessage, ) -> Pin<Box<dyn Future<Output = Result<(), SendError>> + Send + '_>>

Send an event to the consumer (async, with backpressure).

fn clone_box(&self) -> Box<dyn EventSink>

Clone this sink into a boxed trait object.