yngvi 0.2.0

Read, calculate and write weather data
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

use yngvi::core::{InMemWriter, Station};
use yngvi::rtl_433::{rtl_433_file_source, RTL433Reader};

mod error_writer;

#[tokio::test]
async fn should_replay_failed_writes_rtl_433() {
    let mut station = Station::new();

    let source = rtl_433_file_source("data/rtl_433.txt").take(5);
    let reader = RTL433Reader::new(source);

    let mut writer = error_writer::ErrorWriter {};

    station.start(reader, &mut writer).await;

    assert_eq!(station.retry_manager.failed_writes.len(), 5);

    let source = rtl_433_file_source("data/rtl_433.txt").take(5);
    let reader = RTL433Reader::new(source.take(1));

    let mut writer = InMemWriter::new();

    station.start(reader, &mut writer).await;

    assert_eq!(writer.readings.len(), 6);
    assert_eq!(station.retry_manager.failed_writes.len(), 0);
}