Struct servlin::EventSender

pub struct EventSender(pub Option<SyncSender<Event>>);

Tuple Fields

0: Option<SyncSender<Event>>

Implementations

impl EventSender

pub fn unconnected() -> Self

pub fn send(&mut self, event: Event)

Examples found in repository

examples/events-sse.rs (line 56)

fn event_sender_thread(state: Arc<State>, permit: Permit) {
    loop {
        for n in 0..6 {
            std::thread::sleep(Duration::from_secs(1));
            // TODO: Rename Permit::wait and related functions to clarify that they are waiting for
            //       subordinates to drop.
            // TODO: Add a method to wait for a permit to be revoked, and another with a timeout.
            if permit.is_revoked() {
                return;
            }
            for subscriber in state.subscribers.lock().unwrap().iter_mut() {
                subscriber.send(Event::Message(n.to_string()));
            }
        }
        state.subscribers.lock().unwrap().clear();
    }
}

pub fn disconnect(&mut self)

pub fn is_connected(&self) -> bool

Trait Implementations

impl Clone for EventSender

fn clone(&self) -> EventSender

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EventSender

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

Formats the value using the given formatter.

impl PartialEq for EventSender

fn eq(&self, other: &EventSender) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for EventSender

impl StructuralEq for EventSender

impl StructuralPartialEq for EventSender