vyuh 0.2.6

Vyuh web framework for Axum and SQLx with handler-first APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

//! Direct emitter registration.
//!
//! Run:
//!
//! ```sh
//! cargo run --example emitters_direct
//! ```

use std::time::Duration;

use schemars::JsonSchema;
use serde::{Deserialize, Serialize};
use vyuh::{
    Data, bundles,
    emitters::{self, IterCount},
};

#[derive(Clone, Debug, Serialize, Deserialize, JsonSchema)]
struct Heartbeat {
    count: usize,
}

async fn publish_heartbeat(IterCount(count): IterCount) -> Data<Heartbeat> {
    Data::new(Heartbeat { count })
}

#[bundles::signal]
async fn record_heartbeat(payload: Data<Heartbeat>) {
    println!("heartbeat {}", payload.count);
}

fn main() {
    let bundle = bundles::bundle([
        bundles::periodic::<Heartbeat, _, _>(
            publish_heartbeat,
            emitters::PeriodicConf {
                interval: Duration::from_secs(30),
                target: emitters::EmitTarget::Signal,
            },
        ),
        __bundle_part_record_heartbeat(),
    ]);

    assert_eq!(bundle.iter_operations().count(), 2);
    println!("direct emitter registered");
}