aos/events/pong.rs

use aos_configuration as config;
use aos_events_event_loop_runtime::{EventLoopRuntime, Sender, Watcher};
use aos_events_shm_event_loop::ShmEventLoop;
use core::future::Future;
use futures::never::Never;
use std::path::Path;

use ping_rust_fbs::aos::examples as ping;
use pong_rust_fbs::aos::examples as pong;

fn main() {
    aos_init::init();
    let config = config::read_config_from(Path::new("pingpong_config.json")).unwrap();
    ShmEventLoop::new(&config).run_with(|runtime| {
        let task = pong(runtime);
        runtime.spawn(task);
    });
}

/// Responds to ping messages with an equivalent pong.
fn pong(event_loop: &mut EventLoopRuntime) -> impl Future<Output = Never> {
    // The watcher gives us incoming ping messages.
    let mut ping_watcher: Watcher<ping::Ping> = event_loop.make_watcher("/test").unwrap();

    // The sender is used to send messages back to the pong channel.
    let mut pong_sender: Sender<pong::Pong> = event_loop.make_sender("/test").unwrap();
    // Wait for startup.
    let startup = event_loop.on_run();

    async move {
        startup.await;
        loop {
            let ping = dbg!(ping_watcher.next().await);

            let mut builder = pong_sender.make_builder();
            let mut pong = pong::PongBuilder::new(builder.fbb());
            pong.add_value(ping.message().unwrap().value());
            let pong = pong.finish();
            builder.send(pong).expect("Can't send pong reponse");
        }
    }
}