Struct Live 

pub struct Live;

Implementations

impl Live

pub fn publish<T: Serialize + ?Sized>( &self, key: &str, payload: &T, ) -> Result<()>

Examples found in repository

examples/heartbeat_daemon.rs (line 48)

    async fn run(&self, cx: Context) {
        let _ = cx.events().on("heartbeat.ping");
        // Answer pings beside the heartbeat loop.
        let events = cx.clone();
        cx.spawn(async move {
            loop {
                if let Event::Plugin { name, .. } = events.next_event().await
                    && name == "heartbeat.ping"
                {
                    let _ = events.events().emit("heartbeat.pong", &(), Target::All);
                }
            }
        });
        loop {
            self.beats.set(self.beats.get() + 1);
            let _ = cx.live().publish("heartbeat.beat", &self.beats.get());
            cx.sleep(30_000).await;
        }
    }

pub fn delete(&self, key: &str) -> Result<()>

Withdraws the latest value of key: subscribers hear crate::Event::LiveDeleted (a pane that closed, a machine that has nothing to report), and later subscribers see nothing.

pub fn subscribe(&self, prefix: &str) -> Result<()>

pub fn unsubscribe(&self, prefix: &str) -> Result<()>

Trait Implementations

impl Clone for Live

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Live

impl Debug for Live

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

Formats the value using the given formatter.

impl Default for Live

fn default() -> Self

Returns the “default value” for a type.