Struct Events

Source

pub struct Events;

Implementations§

Source §

impl Events

Source

pub fn emit<T: Serialize + ?Sized>( &self, name: &str, payload: &T, to: Target, ) -> Result<()>

Examples found in repository ?

examples/together_companion.rs (line 38)

34fn publish(cx: &Context, state: &str, builds: u32) {
35    let _ = cx
36        .values()
37        .set("together.status", &Status { state, builds });
38    let _ = cx.events().emit("together.changed", &(), Target::Viewers);
39}

More examples

Hide additional examples

examples/heartbeat_daemon.rs (line 42)

33    async fn run(&self, cx: Context) {
34        let _ = cx.events().on("heartbeat.ping");
35        // Answer pings beside the heartbeat loop.
36        let events = cx.clone();
37        cx.spawn(async move {
38            loop {
39                if let Event::Plugin { name, .. } = events.next_event().await
40                    && name == "heartbeat.ping"
41                {
42                    let _ = events.events().emit("heartbeat.pong", &(), Target::All);
43                }
44            }
45        });
46        loop {
47            self.beats.set(self.beats.get() + 1);
48            let _ = cx.live().publish("heartbeat.beat", &self.beats.get());
49            cx.sleep(30_000).await;
50        }
51    }

Source

pub fn on(&self, pattern: &str) -> Result<()>

Listens to events whose names match pattern (git.*).

Examples found in repository ?

examples/together_ui.rs (line 68)

67    fn activate(cx: &mut Context) -> Self {
68        let _ = cx.events().on("together.*");
69        let mut plugin = Self {
70            card: Surface::new("card"),
71            status: Status::default(),
72        };
73        plugin.reload(cx);
74        plugin
75    }

More examples

Hide additional examples

examples/heartbeat_daemon.rs (line 34)

33    async fn run(&self, cx: Context) {
34        let _ = cx.events().on("heartbeat.ping");
35        // Answer pings beside the heartbeat loop.
36        let events = cx.clone();
37        cx.spawn(async move {
38            loop {
39                if let Event::Plugin { name, .. } = events.next_event().await
40                    && name == "heartbeat.ping"
41                {
42                    let _ = events.events().emit("heartbeat.pong", &(), Target::All);
43                }
44            }
45        });
46        loop {
47            self.beats.set(self.beats.get() + 1);
48            let _ = cx.live().publish("heartbeat.beat", &self.beats.get());
49            cx.sleep(30_000).await;
50        }
51    }