We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d1416fa commit cae9d74Copy full SHA for cae9d74
1 file changed
examples/logical_meter.rs
@@ -36,7 +36,7 @@ async fn main() -> Result<(), Error> {
36
let mut battery_rx = formula_battery.subscribe().await?;
37
let mut consumer_rx = formula_consumer.subscribe().await?;
38
39
- loop {
+ for _ in 0..10 {
40
let sample = rx.recv().await.unwrap();
41
let grid_sample = grid_rx.recv().await.unwrap();
42
let battery_sample = battery_rx.recv().await.unwrap();
@@ -49,4 +49,11 @@ async fn main() -> Result<(), Error> {
49
sample.value().unwrap()
50
);
51
}
52
+
53
+ let formula_grid_voltage = logical_meter.grid(metric::AcVoltagePhase1N)?;
54
+ let mut grid_voltage_rx = formula_grid_voltage.subscribe().await?;
55
+ loop {
56
+ let sample = grid_voltage_rx.recv().await.unwrap();
57
+ tracing::info!("grid voltage: {}", sample.value().unwrap());
58
+ }
59
0 commit comments