Struct EventChannel 

pub struct EventChannel<T: 'static> { /* private fields */ }

The producing half of an EventStream.

A service that receives events from outside the composition — a platform callback, a worker thread, a socket — publishes through a channel, and every pending collector is woken. This is the shape that replaces “register an observer, then drain a queue” everywhere in the framework.

Implementations

impl<T: 'static> EventChannel<T>

pub fn new() -> Self

Creates an open channel.

pub fn stream(&self) -> EventStream<T>

The consuming half, handed to collectors.

pub fn send(&self, event: T)

Publishes one event and wakes every pending collector.

pub fn close(&self)

Ends the stream. Collectors drain what is queued and then finish.

pub fn is_closed(&self) -> bool

Whether the channel has been closed.

pub fn pending(&self) -> usize

How many events are queued but not yet taken.

Trait Implementations

impl<T: 'static> Default for EventChannel<T>

fn default() -> Self

Returns the “default value” for a type.